@epikodelabs/streamix / src/public-api / AsyncPushable
Type Alias: AsyncPushable<R>
AsyncPushable<
R> =AsyncIterator<R> &AsyncIterable<R> &object
Defined in: projects/libraries/streamix/src/lib/utils/pushable.ts:17
Async iterator augmented with push methods, passed to operator setup callbacks.
Type Declaration
push()
push(
value):void|Promise<void>
Parameters
value
R
Returns
void | Promise<void>
fail()
fail(
err):void
Parameters
err
any
Returns
void
dispose()
dispose():
void
Returns
void
disposed
Get Signature
get disposed():
boolean
Returns
boolean
Type Parameters
R
R