Skip to content

@epikodelabs/streamix


@epikodelabs/streamix / createAsyncPushable

Function: createAsyncPushable()

createAsyncPushable<R>(): 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

Returns

AsyncPushable<R>

Released under the MIT License.