Function runBoundedPool

runBoundedPool<I, O>(
    items: readonly I[],
    concurrency: number,
    worker: (item: I, index: number) => Promise<O>,
): Promise<O[]>
Ordered bounded worker pool. Runs worker over items with at most concurrency in flight, returning results in INPUT order regardless of completion order.
Type Parameters
- I
- O
Parameters
- items: readonly I[]
- concurrency: number
- worker: (item: I, index: number) => Promise<O>
Returns Promise<O[]>
- Defined in src/core/fanout.ts:105