()
| 65 | } |
| 66 | |
| 67 | startKeepalive(): void { |
| 68 | this.keepaliveInterval = setInterval(() => { |
| 69 | if (this._clientDisconnected || !this.controller) return |
| 70 | try { |
| 71 | this.controller.enqueue(encodeSSEComment('keepalive')) |
| 72 | } catch (error) { |
| 73 | this._clientDisconnected = true |
| 74 | logger.warn('Keepalive enqueue failed, marking client disconnected', { |
| 75 | streamId: this.streamId, |
| 76 | requestId: this.requestId, |
| 77 | error: toError(error).message, |
| 78 | }) |
| 79 | } |
| 80 | }, this.keepaliveMs) |
| 81 | } |
| 82 | |
| 83 | stopKeepalive(): void { |
| 84 | if (this.keepaliveInterval) { |
no test coverage detected