diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js index ed65af9c2de..8c6e1b5b4fd 100644 --- a/lib/_stream_readable.js +++ b/lib/_stream_readable.js @@ -524,10 +524,12 @@ Readable.prototype.addListener = Readable.prototype.on; Readable.prototype.resume = function() { emitDataEvents(this); this.read(0); + this.emit('resume'); }; Readable.prototype.pause = function() { emitDataEvents(this, true); + this.emit('pause'); }; function emitDataEvents(stream, startPaused) { @@ -561,6 +563,7 @@ function emitDataEvents(stream, startPaused) { stream.pause = function() { paused = true; + this.emit('pause'); }; stream.resume = function() { @@ -571,6 +574,7 @@ function emitDataEvents(stream, startPaused) { }); else this.read(0); + this.emit('resume'); }; // now make it start, just in case it hadn't already.