Function runWithConcurrency

runWithConcurrency<T, R>(
    items: readonly T[],
    worker: (item: T, index: number) => Promise<R>,
    options?: ConcurrencyOptions,
): Promise<SettledResult<R>[]>
Run worker over every item with at most concurrency invocations in flight at once. Results are returned in input order and every item settles independently: a rejection is captured, never thrown.
Type Parameters
- T
- R
Parameters
- items: readonly T[]
- worker: (item: T, index: number) => Promise<R>
- options: ConcurrencyOptions = {}
Returns Promise<SettledResult<R>[]>
- Defined in src/core/util/concurrency.ts:33