method StreamClass.chunkEvery
Private
StreamClass.chunkEvery<S>(
source: Source<S>,
count: number,
step?,
leftover?: Exclude<S, AnyFailure>[] | "discard"
): StreamClass<Exclude<S, AnyFailure>[], Extract<S, AnyFailure>>

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

await Stream.chunkEvery([1, 2, 3], 2).collect(); // [[1, 2], [3]]

Type Parameters

Parameters

source: Source<S>
count: number
optional
step = count
optional
leftover: Exclude<S, AnyFailure>[] | "discard"

Return Type

StreamClass<Exclude<S, AnyFailure>[], Extract<S, AnyFailure>>

Usage

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