fixup

Author: ronag

lib/internal/streams/pipeline.js

@@ -341,8 +341,17 @@ function pipe(src, dst) {
   dst
     .on('drain', pump);
 
+  function cleanup() {
+    src
+      .off('end', end)
+      .off('readable', pump);
+    dst
+      .off('drain', pump);
+  }
+
   function end() {
     dst.end();
+    cleanup();
   }
 
   const objectMode = (