Skip to content

@epikodelabs/streamix


@epikodelabs/streamix / src/public-api / createAsyncPushable

Function: createAsyncPushable() ​

createAsyncPushable<R>(options?): AsyncPushable<R>

Defined in: projects/libraries/streamix/src/lib/utils/pushable.ts:28

Creates an AsyncPushable - an async iterator that you can manually push values into with backpressure.

Type Parameters ​

R ​

R

Parameters ​

options? ​

conflate? ​

boolean

Returns ​

AsyncPushable<R>

Released under the MIT License.