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

std/async/pool.ts>pooledMap

Deno standard library
Go to Latest
The Standard Library has been moved to JSR. See the blog post for details.
function pooledMap
import { pooledMap } from "https://deno.land/std@0.190.0/async/pool.ts";

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

If an error is thrown from iterableFn, no new transformations will begin. All currently executing transformations are allowed to finish and still yielded on success. After that, the rejections among them are gathered and thrown by the iterator in an AggregateError.

Examples

Example 1

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

const results = pooledMap(
  2,
  [1, 2, 3],
  (i) => new Promise((r) => setTimeout(() => r(i), 1000)),
);

for await (const value of results) {
  // ...
}

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>