(src)
| 3508 | }; |
| 3509 | |
| 3510 | function pipeOnDrain(src) { |
| 3511 | return function() { |
| 3512 | var dest = this; |
| 3513 | var state = src._readableState; |
| 3514 | state.awaitDrain--; |
| 3515 | if (state.awaitDrain === 0) |
| 3516 | flow(src); |
| 3517 | }; |
| 3518 | } |
| 3519 | |
| 3520 | function flow(src) { |
| 3521 | var state = src._readableState; |