diff --git a/lib/stream.js b/lib/stream.js index d6da2525f95..600416396f0 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -63,9 +63,6 @@ Stream.prototype.pipe = function(dest, options) { if (didOnEnd) return; didOnEnd = true; - // remove the listeners - cleanup(); - dest.end(); } @@ -74,9 +71,6 @@ Stream.prototype.pipe = function(dest, options) { if (didOnEnd) return; didOnEnd = true; - // remove the listeners - cleanup(); - dest.destroy(); }