Skip to content

@epikodelabs/streamix


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

Function: compose()

Call Signature

compose<A, B>(...scripts): Coroutine<A, B>

Defined in: projects/libraries/streamix/coroutines/src/lib/utils/compose.ts:72

Chains multiple coroutines sequentially into a single Coroutine.

CoroutineScript inputs (created by coroutine()) are merged into one worker script so the entire pipeline runs inside one dedicated worker task.

TaskRunner inputs are chained in the main thread after the worker stage completes.

Type Parameters

A

A

B

B

Parameters

scripts

...[CoroutineScript<A, B>]

Returns

Coroutine<A, B>

Call Signature

compose<A, B, C>(...scripts): Coroutine<A, C>

Defined in: projects/libraries/streamix/coroutines/src/lib/utils/compose.ts:73

Chains multiple coroutines sequentially into a single Coroutine.

CoroutineScript inputs (created by coroutine()) are merged into one worker script so the entire pipeline runs inside one dedicated worker task.

TaskRunner inputs are chained in the main thread after the worker stage completes.

Type Parameters

A

A

B

B

C

C

Parameters

scripts

...[CoroutineScript<A, B>, CoroutineScript<B, C>]

Returns

Coroutine<A, C>

Call Signature

compose<A, B, C, D>(...scripts): Coroutine<A, D>

Defined in: projects/libraries/streamix/coroutines/src/lib/utils/compose.ts:74

Chains multiple coroutines sequentially into a single Coroutine.

CoroutineScript inputs (created by coroutine()) are merged into one worker script so the entire pipeline runs inside one dedicated worker task.

TaskRunner inputs are chained in the main thread after the worker stage completes.

Type Parameters

A

A

B

B

C

C

D

D

Parameters

scripts

...[CoroutineScript<A, B>, CoroutineScript<B, C>, CoroutineScript<C, D>]

Returns

Coroutine<A, D>

Call Signature

compose<T, R>(...scripts): Coroutine<T, R>

Defined in: projects/libraries/streamix/coroutines/src/lib/utils/compose.ts:75

Chains multiple coroutines sequentially into a single Coroutine.

CoroutineScript inputs (created by coroutine()) are merged into one worker script so the entire pipeline runs inside one dedicated worker task.

TaskRunner inputs are chained in the main thread after the worker stage completes.

Type Parameters

T

T = any

R

R = any

Parameters

scripts

...(CoroutineScript<any, any> | TaskRunner<any, any>)[]

Returns

Coroutine<T, R>

Released under the GNU AGPL v3 or later.