@epikodelabs/streamix / createPushOperator
Function: createPushOperator()
createPushOperator<
T,R>(name,setup):Operator<T,R>
Defined in: projects/libraries/streamix/src/lib/abstractions/operator.ts:95
Creates a push operator where setup receives the source iterator and a pre-created output. setup may return an optional cleanup callback that is invoked when the downstream cancels iteration (return() / throw()).
Type Parameters
T
T
R
R = T
Parameters
name
string
setup
(source, output) => () => MaybePromise<void>
Returns
Operator<T, R>