()
| 111 | } |
| 112 | |
| 113 | async close(): Promise<void> { |
| 114 | this.stopKeepalive() |
| 115 | this.clearFlushTimer() |
| 116 | await this.flush() |
| 117 | if (!this.controller) return |
| 118 | try { |
| 119 | this.controller.close() |
| 120 | } catch { |
| 121 | // Controller already closed |
| 122 | } |
| 123 | this.controller = null |
| 124 | } |
| 125 | |
| 126 | private enqueue(envelope: PersistedStreamEventEnvelope): void { |
| 127 | if (this._clientDisconnected || !this.controller) return |
nothing calls this directly
no test coverage detected