make duplicate ids impossible

nullsoepic · Sep 24, 2024 · 1c6c3ca · 1c6c3ca
1 parent 8503713
commit 1c6c3ca
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -23,6 +23,9 @@ export class PriorityQueue<T> {
     id: string
   ): Promise<T> {
     return new Promise((resolve, reject) => {
+      if (this.isProcessingOrQueued(id)) {
+        reject(new Error(`Task ${id} is already being processed`));
+      }
       this.queue.push({ fn, args, priority, id, resolve, reject });
       this.queue.sort((a, b) => b.priority - a.priority);
       this.processNextItem();