Fix piping between queues

timursevimli · Jan 13, 2024 · 92e5926 · 92e5926
1 parent 401baa2
commit 92e5926
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/queue.js b/queue.js
@@ -102,7 +102,7 @@ class Queue {
       if (onFailure) onFailure(err, res);
     } else if (onSuccess) onSuccess(res);
     if (onDone) onDone(err, res);
-    if (this.destination) this.destination.add(res);
+    if (this.destination) this.destination.add(res.res);
     if (!onDrain) return;
     if (!this.roundRobinMode) {
       if (this.count === 0 && this.waiting.length === 0) onDrain();
@@ -167,7 +167,7 @@ class Queue {
       throw new Error(msg);
     }
     this.destination = dest;
-    return { pipe: dest.pipe };
+    return { pipe: dest.pipe.bind(dest) };
   }
 
   timeout(msec = 1, onTimeout = null) {