(chunks, length)
| 9871 | stream.on("error", (err) => { |
| 9872 | reject(err); |
| 9873 | }).on("close", () => { |
| 9874 | reject(new TypeError("unusable")); |
| 9875 | }); |
| 9876 | } else { |
| 9877 | reject((_a = rState.errored) != null ? _a : new TypeError("unusable")); |
| 9878 | } |
| 9879 | } else { |
| 9880 | queueMicrotask(() => { |
| 9881 | stream[kConsume] = { |
| 9882 | type, |
| 9883 | stream, |
| 9884 | resolve: resolve2, |
| 9885 | reject, |
| 9886 | length: 0, |
| 9887 | body: [] |
| 9888 | }; |
| 9889 | stream.on("error", function(err) { |
| 9890 | consumeFinish(this[kConsume], err); |
| 9891 | }).on("close", function() { |