@epikodelabs/streamix / nextSourceResult
Function: nextSourceResult()
nextSourceResult<
T,R>(source,onValue,onDone?):Promise<IteratorResult<R,any> | {done:false;value:T;dropped:true; }>
Defined in: projects/libraries/streamix/src/lib/abstractions/operator.ts:68
Pulls a single upstream result for simple operators.
Dropped values are forwarded unchanged so operators that only care about real emissions do not need to repeat that boilerplate in every next() call.
Type Parameters
T
T
R
R = T
Parameters
source
AsyncIterator<T>
onValue
(result) => MaybePromise<IteratorResult<R, any> | { done: false; value: T; dropped: true; }>
onDone?
(result) => MaybePromise<IteratorResult<R, any>>
Returns
Promise<IteratorResult<R, any> | { done: false; value: T; dropped: true; }>