import { AsyncReducer } from "https://deno.land/x/rimbu@1.1.0/stream/main/index.ts";
const { Base } = AsyncReducer;
A base class that can be used to easily create AsyncReducer
instances.
Methods
collectInput<I2>(collectFun: AsyncCollectFun<I2, I>): AsyncReducer<I2, O>
filterInput(pred: () => MaybePromise<boolean>, options?: { negate?: boolean; }): AsyncReducer<I, O>
flatMapInput<I2>(flatMapFun: (value: I2, index: number) => MaybePromise<AsyncStreamSource<I>>): AsyncReducer<I2, O>
sliceInput(from?, amount?: number): AsyncReducer<I, O>