()
| 487 | this.onControlRequestSent(message) |
| 488 | } |
| 489 | const aborted = () => { |
| 490 | this.outbound.enqueue({ |
| 491 | type: 'control_cancel_request', |
| 492 | request_id: requestId, |
| 493 | }) |
| 494 | // Immediately reject the outstanding promise, without |
| 495 | // waiting for the host to acknowledge the cancellation. |
| 496 | const request = this.pendingRequests.get(requestId) |
| 497 | if (request) { |
| 498 | // Track the tool_use ID as resolved before rejecting, so that a |
| 499 | // late response from the host is ignored by the orphan handler. |
| 500 | this.trackResolvedToolUseId(request.request) |
| 501 | request.reject(new AbortError()) |
| 502 | } |
| 503 | } |
| 504 | if (signal) { |
| 505 | signal.addEventListener('abort', aborted, { |
| 506 | once: true, |
nothing calls this directly
no test coverage detected