streams2: flow() is not always bound to src

2012-10-12 10:03:03 -07:00 · 2012-10-12 10:03:03 -07:00 · cf0b4ba410
parent acfb0ef908
commit cf0b4ba410
1 changed files with 2 additions and 2 deletions
--- 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;
  }