(s, o)
| 19811 | ;(j('readable nexttick read 0'), s.read(0)) |
| 19812 | } |
| 19813 | function resume_(s, o) { |
| 19814 | ;(j('resume', o.reading), |
| 19815 | o.reading || s.read(0), |
| 19816 | (o.resumeScheduled = !1), |
| 19817 | s.emit('resume'), |
| 19818 | flow(s), |
| 19819 | o.flowing && !o.reading && s.read(0)) |
| 19820 | } |
| 19821 | function flow(s) { |
| 19822 | var o = s._readableState |
| 19823 | for (j('flow', o.flowing); o.flowing && null !== s.read(); ); |