(stream)
| 24572 | // another read() call => stack overflow. This way, it might trigger |
| 24573 | // a nextTick recursion warning, but that's not so bad. |
| 24574 | function emitReadable(stream) { |
| 24575 | var state = stream._readableState; |
| 24576 | state.needReadable = false; |
| 24577 | if (!state.emittedReadable) { |
| 24578 | debug('emitReadable', state.flowing); |
| 24579 | state.emittedReadable = true; |
| 24580 | if (state.sync) processNextTick(emitReadable_, stream);else emitReadable_(stream); |
| 24581 | } |
| 24582 | } |
| 24583 | |
| 24584 | function emitReadable_(stream) { |
| 24585 | debug('emit readable'); |
no test coverage detected