GraphReFlyTS

API Reference

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

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

Signature

function bufferCount(count: number): Operator<S, S[]>

Parameters

ParameterTypeDescription
countnumbercount value used by the helper.

Returns

A Operator<S, S[]> value.

Example

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

Source

packages/ts/src/graph/combinators.ts