(consume2)
| 9887 | body: [] |
| 9888 | }; |
| 9889 | stream.on("error", function(err) { |
| 9890 | consumeFinish(this[kConsume], err); |
| 9891 | }).on("close", function() { |
| 9892 | if (this[kConsume].body !== null) { |
| 9893 | consumeFinish(this[kConsume], new RequestAbortedError()); |
| 9894 | } |
| 9895 | }); |
| 9896 | consumeStart(stream[kConsume]); |
| 9897 | }); |
| 9898 | } |
| 9899 | }); |
| 9900 | }); |
| 9901 | } |
| 9902 | function consumeStart(consume2) { |
| 9903 | if (consume2.body === null) { |
| 9904 | return; |
| 9905 | } |
| 9906 | const { _readableState: state } = consume2.stream; |
| 9907 | if (state.bufferIndex) { |
| 9908 | const start = state.bufferIndex; |
| 9909 | const end = state.buffer.length; |
| 9910 | for (let n = start; n < end; n++) { |
no test coverage detected