diff --git a/lib/combined-stream2.coffee b/lib/combined-stream2.coffee
index 4cf30ad..1a8368f 100644
--- a/lib/combined-stream2.coffee
+++ b/lib/combined-stream2.coffee
@@ -28,7 +28,7 @@ makeStreams2 = (sourceStream) ->
 		return sourceStream.pipe(new stream.PassThrough())
 
 	debug "wrapping stream..."
-	wrapper = new stream.Readable().wrap(stream)
+	wrapper = new stream.Readable().wrap(sourceStream)
 
 	if sourceStream.destroy?
 		wrapper.destroy = sourceStream.destroy.bind(sourceStream)
diff --git a/lib/combined-stream2.js b/lib/combined-stream2.js
index 425db4a..312c60a 100644
--- a/lib/combined-stream2.js
+++ b/lib/combined-stream2.js
@@ -36,7 +36,7 @@ makeStreams2 = function(sourceStream) {
     return sourceStream.pipe(new stream.PassThrough());
   }
   debug("wrapping stream...");
-  wrapper = new stream.Readable().wrap(stream);
+  wrapper = new stream.Readable().wrap(sourceStream);
   if (sourceStream.destroy != null) {
     wrapper.destroy = sourceStream.destroy.bind(sourceStream);
   }