parallelLimit

parallelLimit(maxConcurrency): <T>(task) => Promise<T>

Creates a limit function that allows you to schedule promises that execute with a maximum concurrency.

Example

const limit = parallelLimit(2)
const tasks = [
  limit(async () => {
      await sleep(100)
      return 1
  }),
  limit(() => 2),
  limit(() => 3),
]
await Promise.all(tasks)
// => [1, 2, 3]

Alternatives

• p-limit

Parameters

maxConcurrency

number

Returns

Function

A limit function.

Type Parameters

• T

Parameters

task

() => T | Promise<T>

Returns

Promise<T>