Feature Request - awaitNextInterval
I'm using the p-queue for throttling, where potentially the API I am trying to hit could still rate limit me.
It would be great if there was a function I could use to handle those timeout after I catch the errors.
const queue = new PQueue({
concurrency: 50,
interval: 10000,
intervalCap: 1000
carryoverConcurrencyCount: true
});
const promises = myObjects.map(
(obj) => async () =>
myApiCall(obj.id).catch((err) => {
if (err.code === HttpStatus.TOO_MANY_REQUESTS) {
queue.awaitNextInterval()
}
this.logger.error(`failed with:`, err);
})
);
await queue.addAll(promises);
sindresorhus / p-queue
Promise queue with concurrency control
3.4k
How does funding with Polar work?
1
Pay now to fund the work behind this issue.
2
Get updates on progress being made.
3
Maintainer is rewarded once the issue is completed.
FAQ
Backer
You're funding impactful open source efforts
Contributor
You want to contribute to this effort
Maintainer
You want to get funding like this too