import { AsyncTransformer } from "https://deno.land/x/rimbu@1.2.1/core/mod.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.
type
{ <T, R>(windowSize: number, options: { skipAmount?: number | undefined; collector: AsyncReducer.Accept<T, R>; }): AsyncTransformer<T, R>; <T>(windowSize: number, options?: { skipAmount?: number | undefined; collector?: undefined; }): AsyncTransformer<T, T[]>; }
type
{ <T, R>(windowSize: number, options: { skipAmount?: number | undefined; collector: AsyncReducer.Accept<T, R>; }): AsyncTransformer<T, R>; <T>(windowSize: number, options?: { skipAmount?: number | undefined; collector?: undefined; }): AsyncTransformer<T, T[]>; }