(listener: () => void)
| 447 | } |
| 448 | |
| 449 | subscribeToReconnects(listener: () => void) { |
| 450 | this.reconnectListeners.add(listener); |
| 451 | |
| 452 | return () => { |
| 453 | this.reconnectListeners.delete(listener); |
| 454 | }; |
| 455 | } |
| 456 | |
| 457 | /** Current connection state — synchronous read. */ |
| 458 | getConnectionState(): ConnectionState { |
no test coverage detected