Skip to content

bufferCount()

Flushes every count values as an array; optional startEvery enables overlapping (sliding) buffers.

Signature

ts
function bufferCount<A>(count: number, startEvery?: number): StoreOperator<A, A[]>

Parameters

ParameterTypeDescription
countnumberBuffer size before flush.
startEverynumberIf set, start a new buffer every N emissions (sliding); omit for tumbling windows.

Returns

StoreOperator&lt;A, A[]&gt; — Tier 2.

Released under the MIT License.