(stream, state)
| 24601 | } |
| 24602 | |
| 24603 | function maybeReadMore_(stream, state) { |
| 24604 | var len = state.length; |
| 24605 | while (!state.reading && !state.flowing && !state.ended && state.length < state.highWaterMark) { |
| 24606 | debug('maybeReadMore read 0'); |
| 24607 | stream.read(0); |
| 24608 | if (len === state.length) |
| 24609 | // didn't get any data, stop spinning. |
| 24610 | break;else len = state.length; |
| 24611 | } |
| 24612 | state.readingMore = false; |
| 24613 | } |
| 24614 | |
| 24615 | // abstract method. to be overridden in specific implementation classes. |
| 24616 | // call cb(er, data) where data is <= n in length. |
nothing calls this directly
no outgoing calls
no test coverage detected