(opts, handler)
| 8034 | this.once("connect", cb); |
| 8035 | } |
| 8036 | [kDispatch](opts, handler) { |
| 8037 | const origin = opts.origin || this[kUrl].origin; |
| 8038 | const request = new Request(origin, opts, handler); |
| 8039 | this[kQueue].push(request); |
| 8040 | if (this[kResuming]) { |
| 8041 | } else if (util.bodyLength(request.body) == null && util.isIterable(request.body)) { |
| 8042 | this[kResuming] = 1; |
| 8043 | queueMicrotask(() => resume(this)); |
| 8044 | } else { |
| 8045 | this[kResume](true); |
| 8046 | } |
| 8047 | if (this[kResuming] && this[kNeedDrain] !== 2 && this[kBusy]) { |
| 8048 | this[kNeedDrain] = 2; |
| 8049 | } |
| 8050 | return this[kNeedDrain] < 2; |
| 8051 | } |
| 8052 | [kClose]() { |
| 8053 | return __async(this, null, function* () { |
| 8054 | return new Promise((resolve2) => { |
nothing calls this directly
no test coverage detected