method StreamClass.flatMap
Private
StreamClass.flatMap<S, U>(
source: Source<S>,
fn: (
value: Exclude<S, AnyFailure>,
index: number
) => Source<U>
): StreamClass<
Exclude<U, AnyFailure>,
Extract<S, AnyFailure> | Extract<U, AnyFailure>
>

StreamClass#flatMap as a static: Stream.flatMap(source, …) is Stream.from(source).flatMap(…).

await Stream.flatMap([1, 2], (n) => [n, n]).collect(); // [1, 1, 2, 2]

Type Parameters

Parameters

source: Source<S>
fn: (
value: Exclude<S, AnyFailure>,
index: number
) => Source<U>

Return Type

StreamClass<
Exclude<U, AnyFailure>,
Extract<S, AnyFailure> | Extract<U, AnyFailure>
>

Usage

import { StreamClass } from "lib/stream/stream.ts";