@epikodelabs/streamix / bufferCount
Function: bufferCount()
bufferCount<
T>(bufferSize):Operator<T,T[]>
Defined in: projects/libraries/streamix/src/lib/operators/bufferCount.ts:11
Buffers a fixed number of values from the source stream and emits them as arrays, tracking pending and phantom values in the PipeContext.
Type Parameters
T
T = any
The type of values in the source stream.
Parameters
bufferSize
MaybePromise<number> = Infinity
The maximum number of values per buffer (default: Infinity).
Returns
Operator<T, T[]>
An Operator instance for use in a stream's pipe method.