@epikodelabs/streamix / bufferUntil
Function: bufferUntil()
bufferUntil<
T>(notifier):Operator<T,T[]>
Defined in: projects/libraries/streamix/src/lib/operators/bufferUntil.ts:29
Buffers values until the notifier emits once, then flushes the collected values.
Every notifier emission triggers a flush of the current buffer; values are released as a collapsed array, preserving metadata for PipeContext tracing. When the source completes, any remaining buffered values are emitted.
Type Parameters
T
T = any
Source value type.
Parameters
notifier
Stream<any>
Stream or Promise whose emissions cause buffer flushes.
Returns
Operator<T, T[]>