method StreamClass.mapConcurrent
Private
StreamClass.mapConcurrent<S, R>(
source: Source<S>,
fn: (
value: Exclude<S, AnyFailure>,
signal: AbortSignal
) => R | PromiseLike<R>,
options?: { maxConcurrency?: number; timeoutMs?: number; ordered?: boolean; }
): StreamClass<
Exclude<R, AnyFailure>,
Extract<S, AnyFailure> | Extract<R, AnyFailure> | AnyFailure
>

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

await Stream.mapConcurrent([1, 2], (n) => n * 2, { maxConcurrency: 2 }).collect(); // [2, 4]

Type Parameters

Parameters

source: Source<S>
fn: (
value: Exclude<S, AnyFailure>,
signal: AbortSignal
) => R | PromiseLike<R>
optional
options: { maxConcurrency?: number; timeoutMs?: number; ordered?: boolean; }

Return Type

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

Usage

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