|
|
@ -36,7 +36,7 @@ makeStreams2 = function(sourceStream) {
|
|
|
|
return sourceStream.pipe(new stream.PassThrough());
|
|
|
|
return sourceStream.pipe(new stream.PassThrough());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
debug("wrapping stream...");
|
|
|
|
debug("wrapping stream...");
|
|
|
|
wrapper = new stream.Readable().wrap(stream);
|
|
|
|
wrapper = new stream.Readable().wrap(sourceStream);
|
|
|
|
if (sourceStream.destroy != null) {
|
|
|
|
if (sourceStream.destroy != null) {
|
|
|
|
wrapper.destroy = sourceStream.destroy.bind(sourceStream);
|
|
|
|
wrapper.destroy = sourceStream.destroy.bind(sourceStream);
|
|
|
|
}
|
|
|
|
}
|
|
|
|