(statusCode, headers, resume, statusText)
| 2044 | return (_b = (_a = this[kHandler]).onResponseStarted) == null ? void 0 : _b.call(_a); |
| 2045 | } |
| 2046 | onHeaders(statusCode, headers, resume, statusText) { |
| 2047 | assert(!this.aborted); |
| 2048 | assert(!this.completed); |
| 2049 | if (channels.headers.hasSubscribers) { |
| 2050 | channels.headers.publish({ request: this, response: { statusCode, headers, statusText } }); |
| 2051 | } |
| 2052 | try { |
| 2053 | return this[kHandler].onHeaders(statusCode, headers, resume, statusText); |
| 2054 | } catch (err) { |
| 2055 | this.abort(err); |
| 2056 | } |
| 2057 | } |
| 2058 | onData(chunk) { |
| 2059 | assert(!this.aborted); |
| 2060 | assert(!this.completed); |
no test coverage detected