From dd4efcd52f1642b429596373127de7edacf9e5b2 Mon Sep 17 00:00:00 2001
From: Koushik Dutta <koushd@gmail.com>
Date: Fri, 17 Nov 2023 20:55:28 -0800
Subject: [PATCH] common: fix waiting dequeues on queue end

---
 common/src/async-queue.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/common/src/async-queue.ts b/common/src/async-queue.ts
index 2646ade3d3..ffe96a747d 100644
--- 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;
     }