| | |
| | | return |
| | | } |
| | | recoverTimer = setInterval(() => { |
| | | if (websocketService.getConnected()) { |
| | | clearInterval(recoverTimer) |
| | | recoverTimer = null |
| | | return |
| | | } |
| | | if (shouldRecoverWS()) { |
| | | if (shouldRecoverWS() && !websocketService.getConnected()) { |
| | | initWS() |
| | | } |
| | | }, 3000) |
| | |
| | | } |
| | | try { |
| | | websocketService.setOnMessageCallback(messageHandler); |
| | | websocketService.setOnOpenCallback(() => { |
| | | if (recoverTimer) { |
| | | clearInterval(recoverTimer) |
| | | recoverTimer = null |
| | | } |
| | | }) |
| | | websocketService.setOnOpenCallback(() => {}) |
| | | websocketService.setOnCloseCallback(() => { |
| | | if (shouldRecoverWS()) { |
| | | ensureRecoverTimer() |