fixup

nodejs · Nov 19, 2021 · 2d35f16 · 2d35f16
1 parent e5c3873
commit 2d35f16
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() {