patch
This commit is contained in:
parent
d8793b0947
commit
f886386374
@ -283,13 +283,12 @@ final class SocketService {
|
|||||||
|
|
||||||
private func handleMissedHeartbeat(for socket: SocketIOClient) {
|
private func handleMissedHeartbeat(for socket: SocketIOClient) {
|
||||||
consecutiveHeartbeatMisses += 1
|
consecutiveHeartbeatMisses += 1
|
||||||
if consecutiveHeartbeatMisses <= maxHeartbeatMissCount {
|
guard consecutiveHeartbeatMisses > maxHeartbeatMissCount else {
|
||||||
updateConnectionState(.connecting)
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
updateConnectionState(.connecting)
|
|
||||||
consecutiveHeartbeatMisses = 0
|
consecutiveHeartbeatMisses = 0
|
||||||
|
updateConnectionState(.connecting)
|
||||||
socket.disconnect()
|
socket.disconnect()
|
||||||
socket.connect(withPayload: currentAuthPayload)
|
socket.connect(withPayload: currentAuthPayload)
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user