concurrentMap | /concurrent-map.ts | asynciter@0.0.15

Using Deno in production at your company? Earn free Deno merch.

Map, filter, reduce for AsyncIterables in Deno.

function concurrentMap

import { concurrentMap } from "https://deno.land/x/asynciter@0.0.15/concurrent-map.ts";

concurrentMap<T, U>(

items: AsyncIterable<T>,

mapFn: (item: T) => Promise<U>,

concurrency?: number,

): AsyncIterableIterator<U>

Map the sequence from one type to another, concurrently.

Items are iterated in order.

Type Parameters

items: AsyncIterable<T>

An iterable collection.

mapFn: (item: T) => Promise<U>

The mapping function.

optional

concurrency: number

AsyncIterableIterator<U>

An iterator of mapped values.