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;
     }