fixup: paused

nodejs · Dec 21, 2019 · a080fd1 · a080fd1
1 parent 906fd31
commit a080fd1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
@@ -182,7 +182,7 @@ ObjectDefineProperty(ReadableState.prototype, 'paused', {
     return this[kPaused] !== false;
   },
   set(value) {
-    this[kPaused] = Boolean(value);
+    this[kPaused] = !!value;
   }
 });
 
@@ -381,7 +381,8 @@ function chunkInvalid(state, chunk) {
 
 
 Readable.prototype.isPaused = function() {
-  return this._readableState[kPaused] === true;
+  const state = this._readableState;
+  return state[kPaused] === true || state.flowing === false;
 };
 
 // Backwards compatibility.