Fix bug in consumer keeping reading after pause/stop

albe · Jul 15, 2018 · 8b0eb1a · 8b0eb1a
1 parent f7d41c7
commit 8b0eb1a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Consumer.js b/src/Consumer.js
@@ -138,6 +138,9 @@ class Consumer extends stream.Readable {
      * @private
      */
     _read() {
+        if (this.isPaused()) {
+            return;
+        }
         this.start();
     }
 }