(stream, state)
| 1273 | } |
| 1274 | |
| 1275 | function resume_(stream, state) { |
| 1276 | debug('resume', (state[kState] & kReading) !== 0); |
| 1277 | if ((state[kState] & kReading) === 0) { |
| 1278 | stream.read(0); |
| 1279 | } |
| 1280 | |
| 1281 | state[kState] &= ~kResumeScheduled; |
| 1282 | stream.emit('resume'); |
| 1283 | flow(stream); |
| 1284 | if ((state[kState] & (kFlowing | kReading)) === kFlowing) |
| 1285 | stream.read(0); |
| 1286 | } |
| 1287 | |
| 1288 | Readable.prototype.pause = function() { |
| 1289 | const state = this._readableState; |