(stream, state)
| 24863 | } |
| 24864 | |
| 24865 | function resume_(stream, state) { |
| 24866 | if (!state.reading) { |
| 24867 | debug('resume read 0'); |
| 24868 | stream.read(0); |
| 24869 | } |
| 24870 | |
| 24871 | state.resumeScheduled = false; |
| 24872 | state.awaitDrain = 0; |
| 24873 | stream.emit('resume'); |
| 24874 | flow(stream); |
| 24875 | if (state.flowing && !state.reading) stream.read(0); |
| 24876 | } |
| 24877 | |
| 24878 | Readable.prototype.pause = function () { |
| 24879 | debug('call pause flowing=%j', this._readableState.flowing); |