diff --git a/lib/chunkstream.js b/lib/chunkstream.js index e8ddac5..e57c1e7 100755 --- a/lib/chunkstream.js +++ b/lib/chunkstream.js @@ -48,14 +48,16 @@ ChunkStream.prototype.read = function(length, callback) { func: callback }); - this._process(); + process.nextTick(function() { + this._process(); - // its paused and there is not enought data then ask for more - if (this._paused && this._reads.length > 0) { - this._paused = false; + // its paused and there is not enought data then ask for more + if (this._paused && this._reads.length > 0) { + this._paused = false; - this.emit('drain'); - } + this.emit('drain'); + } + }.bind(this)); }; ChunkStream.prototype.write = function(data, encoding) {