prevent a promise leak if any of the running resolve first

HalleyAssist · Sep 5, 2023 · be8983e · be8983e
1 parent ae82a4e
commit be8983e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/ThroatQueueFunction.js b/lib/ThroatQueueFunction.js
@@ -8,7 +8,11 @@ function ThroatQueueFunction(n = 5){
         const deferred = Q.defer()
         cancellationState.deferredWrap(deferred)
         running = [...running, deferred.promise]
-        await Q.safeRace(running)
+        try {
+            await Q.safeRace(running)
+        } finally {
+            deferred.resolve(null)
+        }
     }
     let ret = async function(cancellationState, what){
         if(what === null){