import { AsyncTransformer } from "https://deno.land/x/rimbu@1.2.1/stream/async/async-transformer.ts";
const { collect } = AsyncTransformer;
Returns an AsyncTransformer instance that converts or filters its input values using given collectFun before passing them to the reducer.
Parameters
collectFun: AsyncCollectFun<T, R>
- a potentially async function receiving the following arguments, and returns a new value or
skipif the value should be skipped: value: the next valueindex: the value indexskip: a token that, when returned, will not add a value to the resulting collectionhalt: a function that, when called, ensures no next elements are passed