* 设置状态并通知监听器
(newState: WebSocketState)
| 261 | * 设置状态并通知监听器 |
| 262 | */ |
| 263 | private setState(newState: WebSocketState): void { |
| 264 | if (this.state !== newState) { |
| 265 | this.state = newState; |
| 266 | console.log(`[WebSocket] State changed: ${newState}`); |
| 267 | |
| 268 | // 通知所有监听器 |
| 269 | this.stateChangeListeners.forEach((listener) => { |
| 270 | try { |
| 271 | listener(newState); |
| 272 | } catch (error) { |
| 273 | console.error("[WebSocket] State change listener error:", error); |
| 274 | } |
| 275 | }); |
| 276 | } |
| 277 | } |
| 278 | |
| 279 | /** |
| 280 | * 启动心跳 |
no test coverage detected