File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -213,7 +213,9 @@ function Readable(options) {
213
213
Stream . call ( this , options ) ;
214
214
215
215
destroyImpl . construct ( this , ( ) => {
216
- maybeReadMore ( this , this . _readableState ) ;
216
+ if ( ! this . isPaused ( ) ) {
217
+ maybeReadMore ( this , this . _readableState ) ;
218
+ }
217
219
} ) ;
218
220
}
219
221
@@ -633,7 +635,7 @@ function maybeReadMore_(stream, state) {
633
635
// called push() with new data. In this case we skip performing more
634
636
// read()s. The execution ends in this method again after the _read() ends
635
637
// up calling push() with more data.
636
- while ( ! state . reading && ! state . ended && state [ kPaused ] !== true &&
638
+ while ( ! state . reading && ! state . ended &&
637
639
( state . length < state . highWaterMark ||
638
640
( state . flowing && state . length === 0 ) ) ) {
639
641
const len = state . length ;
You can’t perform that action at this time.
0 commit comments