Function timesLimit

src/node/utils/promises.ts:47–58

(total: number, concurrency: number, promiseCreator: Function)

// and each remaining Promise will be created once one of the earlier Promises resolves.) This async
// function resolves once all `total` Promises have resolved.
export const timesLimit = async (total: number, concurrency: number, promiseCreator: Function) => {
  if (total > 0 && concurrency <= 0) throw new RangeError('concurrency must be positive');
  let next = 0;
  const addAnother = () => promiseCreator(next++).finally(() => {
    if (next < total) return addAnother();
  });
  const promises = [];
  for (let i = 0; i < concurrency && i < total; i++) {
    promises.push(addAnother());
  }
  await Promise.all(promises);
};

/**
 * An ordinary Promise except the `resolve` and `reject` executor functions are exposed as