stream: pause/resume on destroyed streams should be noop

Author: ronag

lib/internal/streams/readable.js

@@ -1238,6 +1238,9 @@ function nReadingNextTick(self) {
 // If the user uses them, then switch into old mode.
 Readable.prototype.resume = function() {
   const state = this._readableState;
+  if ((state[kState] & kDestroyed) !== 0) {
+    return this;
+  }
   if ((state[kState] & kFlowing) === 0) {
     debug('resume');
     // We flow only if there is no one listening
@@ -1278,6 +1281,9 @@ function resume_(stream, state) {
 
 Readable.prototype.pause = function() {
   const state = this._readableState;
+  if ((state[kState] & kDestroyed) !== 0) {
+    return this;
+  }
   debug('call pause');
   if ((state[kState] & (kHasFlowing | kFlowing)) !== kHasFlowing) {
     debug('pause');

test/parallel/test-stream-destroy.js

@@ -118,3 +118,13 @@ const http = require('http');
     req.end('asd');
   }));
 }
+
+{
+  // resume() and pause() should be no-ops on destroyed streams.
+  const r = new Readable({ read() {} });
+  r.destroy();
+  r.on('resume', common.mustNotCall());
+  r.on('pause', common.mustNotCall());
+  r.resume();
+  r.pause();
+}