@epikodelabs/streamix / src/public-api / buffer
Function: buffer()
buffer<
T>(period):Operator<T,T[]>
Defined in: projects/libraries/streamix/src/lib/operators/buffer.ts:16
Buffers values from the source stream and emits them as arrays every period milliseconds.
Windows that contain no values are not emitted: a silent period produces no empty-array emission. (RxJS bufferTime emits [] for empty windows; use the flush timing itself only if you do not rely on empty windows.)
Type Parameters
T
T
The type of the values in the source stream.
Parameters
period
number
Time in milliseconds between each buffer flush.
Returns
Operator<T, T[]>
An Operator instance for use in a stream's pipe method.