pooledMap | /async/mod.ts | std@0.80.0

function pooledMap

import { pooledMap } from "https://deno.land/std@0.80.0/async/mod.ts";

pooledMap<T, R>(

poolLimit: number,

array: Iterable<T> | AsyncIterable<T>,

iteratorFn: (data: T) => Promise<R>,

): AsyncIterableIterator<R>

pooledMap transforms values from an (async) iterable into another async iterable. The transforms are done concurrently, with a max concurrency defined by the poolLimit.

Type Parameters

Parameters

poolLimit: number

The maximum count of items being processed concurrently.

array: Iterable<T> | AsyncIterable<T>

The input array for mapping.

iteratorFn: (data: T) => Promise<R>

The function to call for every item of the array.

Returns

AsyncIterableIterator<R>