stream: Fix flow stalled after unpipe()

mpotra · Oct 15, 2017 · 78e855d · 78e855d
1 parent c0a88c8
commit 78e855d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
@@ -626,6 +626,10 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
     if (state.awaitDrain &&
         (!dest._writableState || dest._writableState.needDrain))
       ondrain();
+
+    if (EE.listenerCount(src, 'data') > 0) {
+      state.flowing = true;
+    }
   }
 
   // If the user pushes more data while we're writing to dest then we'll end up