diff --git a/lib/event-stream.js b/lib/event-stream.js index 1ac3b62..7964c94 100644 --- a/lib/event-stream.js +++ b/lib/event-stream.js @@ -22,8 +22,10 @@ function EventStream(emitter, opt) { util.inherits(EventStream, Readable); EventStream.prototype._read = function () { - this._paused = false; - if (this._emitter.resume) this._resumeEmitter.call(this._emitter); + if (this._paused) { + this._paused = false; + if (this._emitter.resume) this._resumeEmitter.call(this._emitter); + } }; module.exports = EventStream;