Skip to content

@epikodelabs/streamix


@epikodelabs/streamix / coroutines/src/public-api / ComputeRunner

Interface: ComputeRunner()<T, R> ​

Defined in: projects/libraries/streamix/coroutines/src/lib/factories/compute.ts:10

Callable pooled compute handle returned by compute().

Type Parameters ​

T ​

T = any

R ​

R = any

ComputeRunner(params): Promise<R>

Defined in: projects/libraries/streamix/coroutines/src/lib/factories/compute.ts:12

Submits input to the compute pool and resolves with the worker result.

Parameters ​

params ​

T | Promise<T>

Returns ​

Promise<R>

Properties ​

finalize ​

finalize: () => Promise<void>

Defined in: projects/libraries/streamix/coroutines/src/lib/factories/compute.ts:14

Terminates all workers in the pool and rejects queued work.

Returns ​

Promise<void>

Released under the GNU AGPL v3 or later.