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.