fixup

Author: ronag

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() {