p-queue
p-queue copied to clipboard
event:active is not emitted after each item processed while setting concurrency greater than 1
active event
const queue = new PQueue({ concurrency: 5 });
queue.addAll(myTaskQueue);
queue.on('active', () => {
console.log(`${queue.size} requests remain to be scraped, pending workers: ${queue.pending}`);
});
console log
5 requests remain to be scraped, pending workers: 4
4 requests remain to be scraped, pending workers: 4
3 requests remain to be scraped, pending workers: 4
2 requests remain to be scraped, pending workers: 4
1 requests remain to be scraped, pending workers: 4
// @timgit
Precisely, it is not emitted on every item processed, my task queue size is 10, however, it only logs the last 5 items.
Could you attach full code to reproduce the bug?