Fix obscure unhandled rejection when calling .clear()

No tests as I was unable to reproduce this… Fixes #119
sindresorhus · Oct 11, 2020 · 933ea23 · 933ea23
1 parent f41d189
commit 933ea23
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/source/index.ts b/source/index.ts
@@ -164,9 +164,14 @@ export default class PQueue<QueueType extends Queue<RunFunction, EnqueueOptionsT
 		if (!this._isPaused) {
 			const canInitializeInterval = !this._isIntervalPaused();
 			if (this._doesIntervalAllowAnother && this._doesConcurrentAllowAnother) {
+				const job = this._queue.dequeue();
+				if (!job) {
+					return false;
+				}
+
 				this.emit('active');
+				job();
 
-				this._queue.dequeue()!();
 				if (canInitializeInterval) {
 					this._initializeIntervalIfNeeded();
 				}