Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/rimbu/stream/async/async-transformer.ts>AsyncTransformer.flatMap

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.
rimbu-org/rimbu
Go to Latest
function AsyncTransformer.flatMap
import { AsyncTransformer } from "https://deno.land/x/rimbu@1.2.1/stream/async/async-transformer.ts";
const { flatMap } = AsyncTransformer;

Returns an async transformer that applies the given flatMap function to each element of the input stream, and concatenates all the resulting resulting streams into one stream.

Parameters

flatMapFun: (
value: T,
index: number,
halt: () => void,
) => MaybePromise<AsyncStreamSource<T2>>
  • a potentially async function that maps each input element to an AsyncStreamSource. The function receives three parameters:
  • value: the current element being processed
  • index: the index of the current element in the input stream
  • halt: a function that can be called to halt further processing of the input stream