@epikodelabs/streamix / buffer
Function: buffer()
buffer<
T>(period):Operator<T,T[]>
Defined in: projects/libraries/streamix/src/lib/operators/buffer.ts:14
Buffers values from the source stream and emits them as arrays every period milliseconds, while tracking pending and phantom values in the PipeContext.
Type Parameters
T
T = any
The type of the values in the source stream.
Parameters
period
MaybePromise<number>
Time in milliseconds between each buffer flush.
Returns
Operator<T, T[]>
An Operator instance for use in a stream's pipe method.