| 8061 | }); |
| 8062 | } |
| 8063 | [kDestroy](err) { |
| 8064 | return __async(this, null, function* () { |
| 8065 | return new Promise((resolve2) => { |
| 8066 | const requests = this[kQueue].splice(this[kPendingIdx]); |
| 8067 | for (let i = 0; i < requests.length; i++) { |
| 8068 | const request = requests[i]; |
| 8069 | util.errorRequest(this, request, err); |
| 8070 | } |
| 8071 | const callback = () => { |
| 8072 | if (this[kClosedResolve]) { |
| 8073 | this[kClosedResolve](); |
| 8074 | this[kClosedResolve] = null; |
| 8075 | } |
| 8076 | resolve2(null); |
| 8077 | }; |
| 8078 | if (this[kHTTPContext]) { |
| 8079 | this[kHTTPContext].destroy(err, callback); |
| 8080 | this[kHTTPContext] = null; |
| 8081 | } else { |
| 8082 | queueMicrotask(callback); |
| 8083 | } |
| 8084 | this[kResume](); |
| 8085 | }); |
| 8086 | }); |
| 8087 | } |
| 8088 | }; |
| 8089 | var createRedirectInterceptor = require_redirect_interceptor(); |
| 8090 | function onError(client, err) { |