File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -64,7 +64,7 @@ public typealias PusherEventJSON = [String: AnyObject]
64
64
}
65
65
66
66
self !. delegate? . debugLog ? ( message: " [PUSHER DEBUG] Network unreachable " )
67
- self !. setConnectionStateToDisconnectedAndResetChannelSubscribedStates ( )
67
+ self !. setConnectionStateToDisconnectedAndReset ( )
68
68
}
69
69
return reachability
70
70
} ( )
@@ -347,11 +347,14 @@ public typealias PusherEventJSON = [String: AnyObject]
347
347
}
348
348
}
349
349
350
- fileprivate func setConnectionStateToDisconnectedAndResetChannelSubscribedStates ( ) {
350
+ fileprivate func setConnectionStateToDisconnectedAndReset ( ) {
351
351
updateConnectionState ( to: . disconnected)
352
352
for (_, channel) in self . channels. channels {
353
353
channel. subscribed = false
354
354
}
355
+ socketConnected = false
356
+ connectionEstablishedMessageReceived = false
357
+ socketId = nil
355
358
attemptReconnect ( )
356
359
}
357
360
@@ -392,7 +395,7 @@ public typealias PusherEventJSON = [String: AnyObject]
392
395
@objc fileprivate func cleanupAfterNoPongResponse( ) {
393
396
pongResponseTimeoutTimer? . invalidate ( )
394
397
pongResponseTimeoutTimer = nil
395
- setConnectionStateToDisconnectedAndResetChannelSubscribedStates ( )
398
+ setConnectionStateToDisconnectedAndReset ( )
396
399
}
397
400
398
401
/**
You can’t perform that action at this time.
0 commit comments