diff --git a/lib/index.js b/lib/index.js
index 9ff6531..92890e8 100755
--- a/lib/index.js
+++ b/lib/index.js
@@ -507,7 +507,7 @@ function defaultReadableOnFinish(readable, callback) {
 }
 
 function pipeReadable(xs, onFinish, stream) {
-    var cleanup = onFinish(xs, streamEndCb);
+    var cleanup = onFinish(xs, streamEndCb, stream);
     var unbound = false;
 
     xs.pipe(stream);