fix: auto reconnection not working

emqx · Jan 7, 2023 · 23767a4 · 23767a4
1 parent cbef88e
commit 23767a4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/Source/CocoaMQTT.swift b/Source/CocoaMQTT.swift
@@ -401,7 +401,6 @@ public class CocoaMQTT: NSObject, CocoaMQTTClient {
     ///         disconnect expectedly
     public func disconnect() {
         internal_disconnect()
-        is_internal_disconnected = false
     }
 
     /// Disconnect unexpectedly
@@ -598,7 +597,7 @@ extension CocoaMQTT: CocoaMQTTSocketDelegate {
         delegate?.mqttDidDisconnect(self, withError: err)
         didDisconnect(self, err)
 
-        guard is_internal_disconnected else {
+        guard !is_internal_disconnected else {
             return
         }
 

diff --git a/Source/CocoaMQTT5.swift b/Source/CocoaMQTT5.swift
@@ -411,12 +411,10 @@ public class CocoaMQTT5: NSObject, CocoaMQTT5Client {
     ///         disconnect expectedly
     public func disconnect() {
         internal_disconnect()
-        is_internal_disconnected = false
     }
 
     public func disconnect(reasonCode : CocoaMQTTDISCONNECTReasonCode,userProperties : [String: String] ) {
         internal_disconnect_withProperties(reasonCode: reasonCode,userProperties: userProperties)
-        is_internal_disconnected = false
     }
 
     /// Disconnect unexpectedly
@@ -644,7 +642,7 @@ extension CocoaMQTT5: CocoaMQTTSocketDelegate {
         delegate?.mqtt5DidDisconnect(self, withError: err)
         didDisconnect(self, err)
 
-        guard is_internal_disconnected else {
+        guard !is_internal_disconnected else {
             return
         }