import { pooledMap } from "https://deno.land/x/proc@0.20.22/legacy/deps.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
Example 1
import { pooledMap } from "https://deno.land/std@0.224.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) {
// ...
}