streams2: flow() is not always bound to src

isaacs · isaacs · commit cf0b4ba4105b · 2012-12-13T17:00:28.000-08:00
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
@@ -289,8 +289,8 @@ function flow(src, pipeOpts) {
     state.flowing = false;
 
     // if there were data event listeners added, then switch to old mode.
-    if (this.listeners('data').length)
-      emitDataEvents(this);
+    if (src.listeners('data').length)
+      emitDataEvents(src);
     return;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -289,8 +289,8 @@ function flow(src, pipeOpts) {`
`289`	`289`	`state.flowing = false;`
`290`	`290`
`291`	`291`	`// if there were data event listeners added, then switch to old mode.`
`292`		`- if (this.listeners('data').length)`
`293`		`- emitDataEvents(this);`
	`292`	`+ if (src.listeners('data').length)`
	`293`	`+ emitDataEvents(src);`
`294`	`294`	`return;`
`295`	`295`	`}`
`296`	`296`