(_controller, err)
| 222 | } |
| 223 | |
| 224 | onResponseError (_controller, err) { |
| 225 | const { res, callback, opaque, body } = this |
| 226 | |
| 227 | removeSignal(this) |
| 228 | |
| 229 | this.factory = null |
| 230 | |
| 231 | if (res) { |
| 232 | this.res = null |
| 233 | util.destroy(res, err) |
| 234 | } else if (callback) { |
| 235 | this.callback = null |
| 236 | queueMicrotask(() => { |
| 237 | this.runInAsyncScope(callback, null, err, { opaque }) |
| 238 | }) |
| 239 | } |
| 240 | |
| 241 | if (body) { |
| 242 | this.body = null |
| 243 | util.destroy(body, err) |
| 244 | } |
| 245 | } |
| 246 | } |
| 247 | |
| 248 | function stream (opts, factory, callback) { |
no test coverage detected