From 5d58704652f951b05f2f3fd30625796645987294 Mon Sep 17 00:00:00 2001 From: Mathew Date: Tue, 5 Sep 2023 21:53:05 +1000 Subject: [PATCH] rr doesnt need the additional members --- lib/ThroatQueueFunction.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/ThroatQueueFunction.js b/lib/ThroatQueueFunction.js index cb68f3f..09220b0 100644 --- a/lib/ThroatQueueFunction.js +++ b/lib/ThroatQueueFunction.js @@ -4,6 +4,7 @@ const NextTickPromise = Q() function ThroatQueueFunction(n = 5){ const running = [] + async function race(cancellationState, running){ const deferred = Q.defer() cancellationState.deferredWrap(deferred) @@ -49,10 +50,9 @@ function ThroatQueueFunction(n = 5){ const r = rFn() const d = Q.defer() const dTrack = Q.defer() - const rr = d.promise - dTrack.promise.id = rr.id = idObj - dTrack.promise.fn = rr.fn = what - dTrack.promise.cancel = rr.cancel = ()=>{ + dTrack.promise.id = idObj + dTrack.promise.fn = what + dTrack.promise.cancel = ()=>{ cancellationState.cancel() } running.push(dTrack.promise)