concurrentUnorderedMap | /tests/deps/asynciter.ts | proc@0.20.22

Module

x/proc/tests/deps/asynciter.ts>concurrentUnorderedMap

A high-level way to run child processes that is easy, flexible, powerful, and prevents resource leaks.

j50n/deno-proc

assertNotStrictEquals

concurrentUnorderedMap

map

dim

red

FormatInputPathObject

SEP

LimitedBytesTransformStream

LimitedTransformStream

TextDelimiterStream

TextLineStream

DelimiterStreamOptions

ReadableStreamFromReaderOptions

WritableStreamFromWriterOptions

DelimiterDisposition

copy

earlyZipReadableStreams

iterateReader

iterateReaderSync

mergeReadableStreams

readableStreamFromIterable

readableStreamFromReader

readAll

readAllSync

readerFromIterable

readerFromStreamReader

toTransformStream

writableStreamFromWriter

writeAll

writeAllSync

writerFromStreamWriter

zipReadableStreams

function concurrentUnorderedMap

Re-export

import { concurrentUnorderedMap } from "https://deno.land/x/proc@0.20.22/tests/deps/asynciter.ts";

concurrentUnorderedMap<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 out of order. This allows maximum concurrency at all times, but the output order cannot be assumed to be the same as the input order.

Type Parameters

Parameters

items: AsyncIterable<T>

An iterable collection.

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

The mapping function.

optional

concurrency: number

Returns

AsyncIterableIterator<U>

An iterator of mapped values.