(src)
| 50193 | }; |
| 50194 | |
| 50195 | function pipeOnDrain(src) { |
| 50196 | return function() { |
| 50197 | var dest = this; |
| 50198 | var state = src._readableState; |
| 50199 | state.awaitDrain--; |
| 50200 | if (state.awaitDrain === 0) |
| 50201 | flow(src); |
| 50202 | }; |
| 50203 | } |
| 50204 | |
| 50205 | function flow(src) { |
| 50206 | var state = src._readableState; |