(state)
| 547 | } |
| 548 | |
| 549 | function canPushMore(state) { |
| 550 | // We can push more data if we are below the highWaterMark. |
| 551 | // Also, if we have no data yet, we can stand some more bytes. |
| 552 | // This is to work around cases where hwm=0, such as the repl. |
| 553 | return (state[kState] & kEnded) === 0 && |
| 554 | (state.length < state.highWaterMark || state.length === 0); |
| 555 | } |
| 556 | |
| 557 | function addChunk(stream, state, chunk, addToFront) { |
| 558 | if ((state[kState] & (kFlowing | kSync | kDataListening)) === (kFlowing | kDataListening) && state.length === 0) { |
no outgoing calls
no test coverage detected
searching dependent graphs…