(src)
| 24753 | }; |
| 24754 | |
| 24755 | function pipeOnDrain(src) { |
| 24756 | return function () { |
| 24757 | var state = src._readableState; |
| 24758 | debug('pipeOnDrain', state.awaitDrain); |
| 24759 | if (state.awaitDrain) state.awaitDrain--; |
| 24760 | if (state.awaitDrain === 0 && EElistenerCount(src, 'data')) { |
| 24761 | state.flowing = true; |
| 24762 | flow(src); |
| 24763 | } |
| 24764 | }; |
| 24765 | } |
| 24766 | |
| 24767 | Readable.prototype.unpipe = function (dest) { |
| 24768 | var state = this._readableState; |
no test coverage detected