fix resume.

talrasha007 · Nov 30, 2014 · 3ce6041 · 3ce6041
1 parent a70955d
commit 3ce6041
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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;