diff --git a/lib/Parser.js b/lib/Parser.js index 167b633..f726245 100644 --- a/lib/Parser.js +++ b/lib/Parser.js @@ -50,9 +50,17 @@ function Parser(stream, debug) { inherits(Parser, EventEmitter); Parser.prototype.setStream = function(stream) { - if (/^v0\.8\./.test(process.version)) - stream = new ReadableStream().wrap(stream); - + if (/^v0\.8\./.test(process.version)) { + var newStream = new ReadableStream(), + wrapped = newStream.wrap(stream); + // as of now, 07/02/2013, the readable-stream module is behind in updates + // and has different behavior for the return value of wrap() compared to + // node v0.10+, so we check for that here ... + if (wrapped) + stream = wrapped; + else + stream = newStream; + } this._stream = stream; };