(s)
| 19777 | u.nextTick(emitReadable_, s))) |
| 19778 | } |
| 19779 | function emitReadable_(s) { |
| 19780 | var o = s._readableState |
| 19781 | ;(j('emitReadable_', o.destroyed, o.length, o.ended), |
| 19782 | o.destroyed || |
| 19783 | (!o.length && !o.ended) || |
| 19784 | (s.emit('readable'), (o.emittedReadable = !1)), |
| 19785 | (o.needReadable = !o.flowing && !o.ended && o.length <= o.highWaterMark), |
| 19786 | flow(s)) |
| 19787 | } |
| 19788 | function maybeReadMore(s, o) { |
| 19789 | o.readingMore || ((o.readingMore = !0), u.nextTick(maybeReadMore_, s, o)) |
| 19790 | } |
no test coverage detected