method StreamClass.chunkBy
Private
StreamClass.chunkBy<S>(
source: Source<S>,
key: (value: Exclude<S, AnyFailure>) => unknown
): StreamClass<Exclude<S, AnyFailure>[], Extract<S, AnyFailure>>

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

await Stream.chunkBy([1, 1, 2], (n) => n).collect(); // [[1, 1], [2]]

Type Parameters

Parameters

source: Source<S>
key: (value: Exclude<S, AnyFailure>) => unknown

Return Type

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

Usage

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