fixup

nodejs · Nov 10, 2021 · 16a2fb6 · 16a2fb6
1 parent f407d7f
commit 16a2fb6
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -333,8 +333,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 = (