(self, signal)
| 10209 | util.parseHeaders(trailers, this.trailers); |
| 10210 | this.res.push(null); |
| 10211 | } |
| 10212 | onError(err) { |
| 10213 | const { res, callback, body, opaque } = this; |
| 10214 | if (callback) { |
| 10215 | this.callback = null; |
| 10216 | queueMicrotask(() => { |
| 10217 | this.runInAsyncScope(callback, null, err, { opaque }); |
| 10218 | }); |
| 10219 | } |
| 10220 | if (res) { |
| 10221 | this.res = null; |
| 10222 | queueMicrotask(() => { |
| 10223 | util.destroy(res, err); |
| 10224 | }); |
| 10225 | } |
| 10226 | if (body) { |
| 10227 | this.body = null; |
| 10228 | util.destroy(body, err); |
| 10229 | } |
| 10230 | if (this.removeAbortListener) { |
no test coverage detected