mapWithLimit

mapWithLimit<T, R>(items, concurrency, fn): Promise<R[]>

Defined in: packages/synapse-core/src/utils/concurrency.ts:63

Like Promise.all(items.map(fn)), but runs at most concurrency calls at a time.

Type Parameters

Type Parameter
T
R

Parameters

Parameter	Type	Description
items	readonly T[]	The inputs.
concurrency	number	The maximum number of concurrent calls.
fn	(item, index) => Promise<R>	The async work per item.

Returns

Promise<R[]>

The results, in input order.

Example

import { mapWithLimit } from '@filoz/synapse-core/utils'

const pieces = await mapWithLimit(dataSets, 4, (dataSet) => loadPieces(dataSet))