streams: resume/pause should not fire after end

1 files changed, 5 insertions, 1 deletions

diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
index e87c9f293..ec050811f 100644
--- a/lib/_stream_readable.js
+++ b/lib/_stream_readable.js
@@ -738,6 +738,9 @@ function resume(stream, state) {
 }
 
 function resume_(stream, state) {
+  if (state.ended)
+    return;
+
   if (!state.reading) {
     debug('resume read 0');
     stream.read(0);
@@ -752,7 +755,8 @@ function resume_(stream, state) {
 
 Readable.prototype.pause = function() {
   debug('call pause flowing=%j', this._readableState.flowing);
-  if (false !== this._readableState.flowing) {
+  if (false !== this._readableState.flowing &&
+      !this._readableState.ended) {
     debug('pause');
     this._readableState.flowing = false;
     this.emit('pause');