import { AsyncTransformer } from "https://deno.land/x/rimbu@1.0.0/stream/main/index.ts";
const { window } = AsyncTransformer;
Returns an async transformer that produces windows/collections of windowSize size, each
window starting skipAmount of elements after the previous, and optionally collected
by a custom reducer.
Examples
Example 1
Example 1
await AsyncStream.of(1, 2, 3, 4, 5, 6)
.transform(AsyncTransformer.window(3))
.toArray()
// => [[1, 2, 3], [4, 5, 6]]
type
{ <T>(windowSize: number, skipAmount?: number): AsyncTransformer<T, T[]>; <T, R>(): AsyncTransformer<T, R>; }