(reason)
| 628 | } |
| 629 | }, |
| 630 | async cancel(reason) { |
| 631 | logger.info(`[${requestId}] Streaming response cancelled`, { reason }) |
| 632 | timeoutController.abort() |
| 633 | timeoutController.cleanup() |
| 634 | if (executionId) { |
| 635 | try { |
| 636 | await cleanupExecutionBase64Cache(executionId) |
| 637 | } catch (error) { |
| 638 | logger.error(`[${requestId}] Failed to cleanup base64 cache`, { error }) |
| 639 | } |
| 640 | } |
| 641 | }, |
| 642 | }) |
| 643 | } |
nothing calls this directly
no test coverage detected