common: fix waiting dequeues on queue end

koush · Nov 18, 2023 · dd4efcd · dd4efcd
1 parent eab0746
commit dd4efcd
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/common/src/async-queue.ts b/common/src/async-queue.ts
@@ -67,7 +67,10 @@ export function createAsyncQueue<T>() {
             return false;
         // catch to prevent unhandled rejection.
         ended = e || new EndError()
-        clear(e);
+        clear(ended);
+        while (waiting.length) {
+            waiting.shift().reject(ended);
+        }
         return true;
     }