(action: PayloadAction<any>)
| 168 | } |
| 169 | |
| 170 | sendMessage(action: PayloadAction<any>) { |
| 171 | if (this.socket.readyState === WebSocket.OPEN) { |
| 172 | this.socket.send(JSON.stringify(action)); |
| 173 | } else if (this.socket.readyState === WebSocket.CONNECTING) { |
| 174 | this.messageQueue.push(action); |
| 175 | } else { |
| 176 | console.error("WebSocket is not open. Cannot send:", action); |
| 177 | } |
| 178 | } |
| 179 | |
| 180 | queueOrDispatch(resource: Resource, action: Action) { |
| 181 | const queue = this.activeFetches[resource]; |
no test coverage detected