fixup

nodejs · Jun 11, 2021 · 1b18705 · 1b18705
1 parent 0ba9820
commit 1b18705
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -120,9 +120,12 @@ async function pump(iterable, writable, finish) {
   };
 
   const waitForDrain = () => new Promise((resolve) => {
-    if (error || writable.destroyed) return resolve();
     assert.strictEqual(callback, noop);
-    callback = resolve;
+    if (error || writable.destroyed) {
+      resolve();
+    } else {
+      callback = resolve;
+    }
   })
 
   writable