fixup

nodejs · ronag · Jun 11, 2021 · Jun 11, 2021 · Jun 11, 2021 · Jun 11, 2021
commit c23ab6439bca2cf79b0dfbf8e1deb00e45da29ec
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -140,15 +140,24 @@ async function pump(iterable, writable, finish) {
       await waitForDrain();
     }
 
+    if (error) {
+      return;
+    }
+
     for await (const chunk of iterable) {
       if (!writable.write(chunk)) {
         await waitForDrain();
       }
+      if (error) {
+        return;
+      }
     }
 
-    if (!error) {
-      writable.end();
+    if (error) {
+      return;
     }
+
+    writable.end();
   } catch (err) {
     error = aggregateTwoErrors(error, err);
   } finally {