(consume2, err)
| 9910 | for (let n = start; n < end; n++) { |
| 9911 | consumePush(consume2, state.buffer[n]); |
| 9912 | } |
| 9913 | } else { |
| 9914 | for (const chunk of state.buffer) { |
| 9915 | consumePush(consume2, chunk); |
| 9916 | } |
| 9917 | } |
| 9918 | if (state.endEmitted) { |
| 9919 | consumeEnd(this[kConsume]); |
| 9920 | } else { |
| 9921 | consume2.stream.on("end", function() { |
| 9922 | consumeEnd(this[kConsume]); |
| 9923 | }); |
| 9924 | } |
| 9925 | consume2.stream.resume(); |
| 9926 | while (consume2.stream.read() != null) { |
| 9927 | } |
| 9928 | } |
| 9929 | function chunksDecode(chunks, length) { |
| 9930 | if (chunks.length === 0 || length === 0) { |
no outgoing calls
no test coverage detected