@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:18
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>
error()
error(
err):void
Parameters
err
any
Returns
void
complete()
complete():
void
Returns
void
completed()
completed():
boolean
Returns
boolean
Type Parameters
R
R