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

dispose()

dispose: () => 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.