| 9871 | if (this[kConsume].body !== null) { |
| 9872 | consumeFinish(this[kConsume], new RequestAbortedError()); |
| 9873 | } |
| 9874 | }); |
| 9875 | consumeStart(stream[kConsume]); |
| 9876 | }); |
| 9877 | } |
| 9878 | }); |
| 9879 | }); |
| 9880 | } |
| 9881 | function consumeStart(consume2) { |
| 9882 | if (consume2.body === null) { |
| 9883 | return; |
| 9884 | } |
| 9885 | const { _readableState: state } = consume2.stream; |
| 9886 | if (state.bufferIndex) { |
| 9887 | const start = state.bufferIndex; |
| 9888 | const end = state.buffer.length; |
| 9889 | for (let n = start; n < end; n++) { |
| 9890 | consumePush(consume2, state.buffer[n]); |
| 9891 | } |