Skip to content
PACKAGES

bufferCount()

bufferCount: batch consecutive source DATA into arrays of length count; the remainder flushes on source COMPLETE. Single dep + ctx.state buffer + completeWhenDepsComplete:false + terminalAsRealInput:true.

import { bufferCount } from "@graphrefly/ts/operators";
function bufferCount(count: number): Operator<S, S[]>
ParameterTypeDescription
countnumbercount value used by the helper.

A Operator<S, S[]> value.

import { bufferCount } from "@graphrefly/ts/operators";

packages/ts/src/graph/combinators.ts