method StreamClass.chunkWhile
Private
StreamClass.chunkWhile<S, A, C>(
source: Source<S>,
initial: A,
step: (
value: Exclude<S, AnyFailure>,
accumulator: A
) => { acc: A; emit?: C; halt?: boolean; },
flush?: (accumulator: A) => C | undefined
): StreamClass<C, Extract<S, AnyFailure>>

StreamClass#chunkWhile as a static: Stream.chunkWhile(source, …) is Stream.from(source).chunkWhile(…).

await Stream.chunkWhile([1, 2], 0, (v, acc) => ({ acc: acc + v, emit: [v] })).collect(); // [[1], [2]]

Type Parameters

Parameters

source: Source<S>
initial: A
step: (
value: Exclude<S, AnyFailure>,
accumulator: A
) => { acc: A; emit?: C; halt?: boolean; }
optional
flush: (accumulator: A) => C | undefined

Return Type

StreamClass<C, Extract<S, AnyFailure>>

Usage

import { StreamClass } from "lib/stream/stream.ts";