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 GNU AGPL v3 or later.