diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index 180ab1d55b6..06797c4ea15 100644
--- 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;
   }