fixup

nodejs · Nov 22, 2021 · 77eeaa1 · 77eeaa1
1 parent bbfe81a
commit 77eeaa1
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -330,16 +330,20 @@ function pipe(src, dst) {
 
   src
     .on('end', end)
-    .on('readable', pump);
+    .on('readable', pump)
+    .on('error', cleanup);
   dst
-    .on('drain', pump);
+    .on('drain', pump)
+    .on('error', cleanup);
 
   function cleanup() {
     src
       .off('end', end)
-      .off('readable', pump);
+      .off('readable', pump)
+      .off('error', cleanup);
     dst
-      .off('drain', pump);
+      .off('drain', pump)
+      .off('error', cleanup);
   }
 
   function end() {