(s, o)
| 19823 | for (j('flow', o.flowing); o.flowing && null !== s.read(); ); |
| 19824 | } |
| 19825 | function fromList(s, o) { |
| 19826 | return 0 === o.length |
| 19827 | ? null |
| 19828 | : (o.objectMode |
| 19829 | ? (i = o.buffer.shift()) |
| 19830 | : !s || s >= o.length |
| 19831 | ? ((i = o.decoder |
| 19832 | ? o.buffer.join('') |
| 19833 | : 1 === o.buffer.length |
| 19834 | ? o.buffer.first() |
| 19835 | : o.buffer.concat(o.length)), |
| 19836 | o.buffer.clear()) |
| 19837 | : (i = o.buffer.consume(s, o.decoder)), |
| 19838 | i) |
| 19839 | var i |
| 19840 | } |
| 19841 | function endReadable(s) { |
| 19842 | var o = s._readableState |
| 19843 | ;(j('endReadable', o.endEmitted), |
no test coverage detected