concurrentMap | /mod.ts | asynciter@0.0.18

Map, filter, reduce for AsyncIterables in Deno.

Latest

function concurrentMap

Re-export

import { concurrentMap } from "https://deno.land/x/asynciter@0.0.18/mod.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.