sindresorhus/
Promise queue with concurrency control
USD raised
Recent activities
Add an option to add a timeout for queue members
100% coverage
TypeError: PQueue is not a constructor
Documentation: I feel I have a use-case that I'm not sure if the queue fulfils when reading the doc
[Feature request] Get number of tasks before one
Jest detects open handles on queue.add()
Default value for priority doesn't get applied
How do I only add items up until the concurrency limit and then wait until a pending promise is fulfilled?
`PQueue.on` does not exist
How can I use jest fake timers when testing code that use p-queue?
EventEmitter import breaks TypeScript
[7.4.0] Type regression when node16 module/moduleResolution
Weakmap.get is not a function
[react-native] privateMap.get is not a function
p-queue is not correctly exported and breaks Bundlephobia and unpkg.
AsyncLocalStorage execution context not propagated correctly
TypeScript TS2344 error with enabled "exactOptionalPropertyTypes" setting.
internal `pending` count out of sync
Aborting pending and waiting tasks at the same time hangs the queue
Again '/node_modules/eventemitter3/index.js' does not provide an export named 'default'
'/node_modules/eventemitter3/index.js' does not provide an export named 'default'
Timeout option question
Next `interval` is ignored after `await queue.add(...)`
can not run on react-native project
`error` and `completed` events not emitted on v6
Doc request: Why is "concurrency" not working as expected?
Multiple interval/intervalCap constraints?
latest update causes all instances of `add` to return response | void
Version 7.3.1 appears to be broken
Support deno
How to properly handle exceptions to avoid process exiting?
Event handler for 'error'
Build script fails with "del: not found"
Testing `complete` event when its the only non-respondent event.
Getting queued results back in order
How do I remove a specific queue'd item?
Abort during task setup is missed before the running listener is registered
Adding tasks from an active listener exceeds the concurrency limit
`.add()` does not check `isPaused`, queue can grow unbounded after `.pause()`
Fixed-window rate limiter incorrectly delays tasks in a new interval when `intervalCap > 1` and queue went idle mid-window
Per-task `timeout` in `add()` skips validation that the constructor enforces
onSizeLessThan() resolves late when the queue drains without a completion
Enhancement: add timeoutRemaining to running task info
signal option does not reject when task is aborted while queued
clear() should reject pending tasks?
`completed` event never sent on timeout
`idle` never fires when queue never receives tasks
Consider "strict" argument for sliding window rate limit
awaiting for queue.add makes it non-concurrent and not-a-queue
[Feature Request] API RateLimit adaptable mode
Getting queued results back in order PROGRESSIVELY
Feature Request - awaitNextInterval
Remove from Pending tasks
event:active is not emitted after each item processed while setting concurrency greater than 1
No identifiers allowed directly after numeric literal
Item specific concurrency limit
Can we change the node version to be compatible with 16 or 18 on last version?
Abort signals don't remove tasks from the queue
RangeError: Maximum call stack size exceeded
[Bug] Wrong type in package.json
This documentation looks very legit. It's AI generated from the tests, and some prompting.....
Allow not to copy/paste throwOnTimeout
Clarify the documentation for "add"?
BUG: function_ is not a function
One Queue, Multiple workers
Is it feasible to change priority of a Queued item on the fly
Possibility to tap into already executed data
Publish a new version for support TypeScript v3.9
Throw error if exceeding x amount of items, stop queue
size and pending bad experience
`carryoverConcurrencyCount` docs are vague
Timeout documentation
Other events
Add function should not be async
add() function doesnt do anything after extended use
Howto: Wait for currently executing tasks to complete
Reaching 100% coverage (pt 2)
Know what is the priority of the current running function
Where TaskResultType place?
refactor: async is unnecessary.
'next' doesn't work.
UnhandledPromiseRejectionWarning
Vague Documentation
Adding items to current queue?
Question on usage
onSuccess?
Rejecting the whole queue when a task rejects
How to add to queue asynchronously?
Timeout documentation and questions
Possible memory leak?
Helper method to emulate add(() => {})
Change output target to ES5 please
CustomQueue doesn't work?
An unhandled exception occurred: Unexpected token: keyword (default)
Backpressure
Property '_doesIntervalAllowAnother' implicitly has type 'any'
Build broken in 6.2.1
onIdle is not called
Thank you
pqueue clear no effect
DeprecationWarning: No "main" or "exports" field defined in the package.json
Module not found: Error: Can't resolve 'p-queue' after updating to 7.1.0
eventemitter can only ve default-imported using the esModuleInterop flag
native esm is experimental and doesn't yet work with test or monitoring code that must manipulate the code
queue resources
Must use import to load ES Module
Error in Typescript
queue.on on not working
Check each batch results before continue
Error [ERR_REQUIRE_ESM]: Must use import to load ES Module
If `throwOnTimeout` is `false` - `add()` resolves to undefined
Maintainer wanted
Use `EventTarget` when targeting Node.js 26
p-queue hanging
Maintenance of last Non-ESM release
Module not found: Can't resolve 'p-queue' in xxx at `7.3.0`
#isIntervalPaused maybe useless
onEmpty/onIdle misusing Promises
Using p-queue with `require`
Module not found
make PriorityQueue array protected rather than private
Does it work across multiple Node.js processes?
'p-timeout' is expected to be of type CommonJS - Why Am I Getting This Error? v7.0.0
Cannot find module 'p-queue' from 'test/q.test.ts'
Imports broken
Why must wait for `n` tasks added when set concurrency = `n`
Feature request: onSize promise
Usage with ESM in NodeJS is unintuitive
intervalCap not respected when using large intervalCaps or small intervals
Improve name of `carryoverConcurrencyCount` option
Support `AbortController`
REST calls not triggered to run till entire queue added.
Š 2019 BoostIO, Inc.