(statusCode, headers, resume, statusText)
| 2953 | return this[kHandler].onResponseStarted?.(); |
| 2954 | } |
| 2955 | onResponseStart(statusCode, headers, resume, statusText) { |
| 2956 | assert(!this.aborted); |
| 2957 | assert(!this.completed); |
| 2958 | if (channels.headers.hasSubscribers) { |
| 2959 | channels.headers.publish({ request: this, response: { statusCode, headers, statusText } }); |
| 2960 | } |
| 2961 | const controller = this[kController]; |
| 2962 | if (controller) { |
| 2963 | controller[kResume] = resume; |
| 2964 | controller.rawHeaders = headers; |
| 2965 | } |
| 2966 | const parsedHeaders = Array.isArray(headers) ? parseHeaders(headers) : headers; |
| 2967 | try { |
| 2968 | this[kHandler].onResponseStart?.(controller, statusCode, parsedHeaders, statusText); |
| 2969 | return !controller?.paused; |
| 2970 | } catch (err) { |
| 2971 | this.abort(err); |
| 2972 | return false; |
| 2973 | } |
| 2974 | } |
| 2975 | onResponseData(chunk) { |
| 2976 | assert(!this.aborted); |
| 2977 | assert(!this.completed); |
nothing calls this directly
no test coverage detected