streams2: Set flowing=true when flowing

diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index b71c22a..7b2d76c 100644 (file)
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -159,8 +159,10 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
   dest.emit('pipe', src);
 
   // start the flow.
-  if (!state.flowing)
+  if (!state.flowing) {
+    state.flowing = true;
     process.nextTick(flow.bind(null, src, pipeOpts));
+  }
 
   return dest;
 };
@@ -168,7 +170,6 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
 function flow(src, pipeOpts) {
   var state = src._readableState;
   var chunk;
-  var dest;
   var needDrain = 0;
 
   function ondrain() {