import { type AsyncReducer } from "https://deno.land/x/rimbu@1.2.1/mod.ts";
const { Impl } = AsyncReducer;
The AsyncReducer implementation interface defining the required methods.
Properties
The initial state value for the reducer algorithm.
An optional function that is called when the reducer will no longer receive values.
Returns an AsyncReducer instance that converts its input values using given mapFun before passing them to the reducer.
Methods
Returns an AsyncReducer instance that only passes values to the reducer that satisy the given pred predicate.
Returns an AsyncReducer instance that converts its input values using given flatMapFun before passing them to the reducer.
Returns an AsyncReducer instance that converts or filters its input values using given collectFun before passing them to the reducer.
Returns an AsyncReducer instance that converts its output values using given mapFun.
Returns an AsyncReducer instance that takes at most the given amount of input elements, and will ignore subsequent elements.
Returns an AsyncReducer instance that skips the first given amount of input elements, and will process subsequent elements.
Returns an AsyncReducer instance that takes given amount of elements starting at given from index, and ignores other elements.
Returns an 'AsyncReducerinstance that produces at mostamount` values.
Returns an 'AsyncReducerinstance that produces until the givenpred` predicate returns true for
the output value.
Returns a reducer that applies the given nextReducers sequentially after this reducer
has halted, and moving on to the next provided reducer until it is halted. Optionally, it provides the last output
value of the previous reducer.
Returns a promise that resolves to a 'runnable' instance of the current reducer specification. This instance maintains its own state and indices, so that the instance only needs to be provided the input values, and output values can be retrieved when needed. The state is kept private.
Properties
The initial state value for the reducer algorithm.
An optional function that is called when the reducer will no longer receive values.
Returns an AsyncReducer instance that converts its input values using given mapFun before passing them to the reducer.
Methods
Returns an AsyncReducer instance that only passes values to the reducer that satisy the given pred predicate.
Returns an AsyncReducer instance that converts its input values using given flatMapFun before passing them to the reducer.
Returns an AsyncReducer instance that converts or filters its input values using given collectFun before passing them to the reducer.
Returns an AsyncReducer instance that converts its output values using given mapFun.
Returns an AsyncReducer instance that takes at most the given amount of input elements, and will ignore subsequent elements.
Returns an AsyncReducer instance that skips the first given amount of input elements, and will process subsequent elements.
Returns an AsyncReducer instance that takes given amount of elements starting at given from index, and ignores other elements.
Returns an 'AsyncReducerinstance that produces at mostamount` values.
Returns an 'AsyncReducerinstance that produces until the givenpred` predicate returns true for
the output value.
Returns a reducer that applies the given nextReducers sequentially after this reducer
has halted, and moving on to the next provided reducer until it is halted. Optionally, it provides the last output
value of the previous reducer.
Returns a promise that resolves to a 'runnable' instance of the current reducer specification. This instance maintains its own state and indices, so that the instance only needs to be provided the input values, and output values can be retrieved when needed. The state is kept private.