(chunks, length)
| 9862 | } |
| 9863 | function consume(stream, type) { |
| 9864 | return __async(this, null, function* () { |
| 9865 | assert(!stream[kConsume]); |
| 9866 | return new Promise((resolve2, reject) => { |
| 9867 | var _a; |
| 9868 | if (isUnusable(stream)) { |
| 9869 | const rState = stream._readableState; |
| 9870 | if (rState.destroyed && rState.closeEmitted === false) { |
| 9871 | stream.on("error", (err) => { |
| 9872 | reject(err); |
| 9873 | }).on("close", () => { |
| 9874 | reject(new TypeError("unusable")); |
| 9875 | }); |
no outgoing calls
no test coverage detected