Add run loop parameter

Author: jcavar

MQTTClient/MQTTClient/MQTTSessionManager.h

@@ -211,6 +211,7 @@ typedef NS_ENUM(int, MQTTSessionManagerState) {
  * @param securityPolicy A custom SSL security policy or nil.
  * @param certificates An NSArray of the pinned certificates to use or nil.
  * @param protocolLevel Protocol version of the connection.
+ * @param runLoop Run loop for MQTTSession.
  */
 
 - (void)connectTo:(NSString *)host
@@ -229,7 +230,8 @@ typedef NS_ENUM(int, MQTTSessionManagerState) {
      withClientId:(NSString *)clientId
    securityPolicy:(MQTTSSLSecurityPolicy *)securityPolicy
      certificates:(NSArray *)certificates
-    protocolLevel:(MQTTProtocolVersion)protocolLevel;
+    protocolLevel:(MQTTProtocolVersion)protocolLevel
+          runLoop:(NSRunLoop *)runLoop;
 
 
 /** Connects to the MQTT broker and stores the parameters for subsequent reconnects

MQTTClient/MQTTClient/MQTTSessionManager.m

@@ -36,6 +36,7 @@ @interface MQTTSessionManager()
 @property (nonatomic) NSInteger willQos;
 @property (nonatomic) BOOL willRetainFlag;
 @property (strong, nonatomic) NSString *clientId;
+@property (strong, nonatomic) NSRunLoop *runLoop;
 @property (strong, nonatomic) MQTTSSLSecurityPolicy *securityPolicy;
 @property (strong, nonatomic) NSArray *certificates;
 @property (nonatomic) MQTTProtocolVersion protocolLevel;
@@ -223,7 +224,8 @@ - (void)connectTo:(NSString *)host
        withClientId:clientId
      securityPolicy:securityPolicy
        certificates:certificates
-      protocolLevel:MQTTProtocolVersion311]; // use this level as default, keeps it backwards compatible
+      protocolLevel:MQTTProtocolVersion311 // use this level as default, keeps it backwards compatible
+            runLoop:[NSRunLoop currentRunLoop]];
 }
 
 - (void)connectTo:(NSString *)host
@@ -242,7 +244,8 @@ - (void)connectTo:(NSString *)host
      withClientId:(NSString *)clientId
    securityPolicy:(MQTTSSLSecurityPolicy *)securityPolicy
      certificates:(NSArray *)certificates
-    protocolLevel:(MQTTProtocolVersion)protocolLevel {
+    protocolLevel:(MQTTProtocolVersion)protocolLevel
+          runLoop:(NSRunLoop *)runLoop {
     DDLogVerbose(@"MQTTSessionManager connectTo:%@", host);
     BOOL shouldReconnect = self.session != nil;
     if (!self.session ||
@@ -260,7 +263,8 @@ - (void)connectTo:(NSString *)host
         willRetainFlag != self.willRetainFlag ||
         ![clientId isEqualToString:self.clientId] ||
         securityPolicy != self.securityPolicy ||
-        certificates != self.certificates) {
+        certificates != self.certificates ||
+        runLoop != self.runLoop) {
         self.host = host;
         self.port = (int)port;
         self.tls = tls;
@@ -278,7 +282,8 @@ - (void)connectTo:(NSString *)host
         self.securityPolicy = securityPolicy;
         self.certificates = certificates;
         self.protocolLevel = protocolLevel;
-
+        self.runLoop = runLoop;
+        
         self.session = [[MQTTSession alloc] initWithClientId:clientId
                                                     userName:auth ? user : nil
                                                     password:auth ? pass : nil
@@ -290,7 +295,7 @@ - (void)connectTo:(NSString *)host
                                                      willQoS:willQos
                                               willRetainFlag:willRetainFlag
                                                protocolLevel:protocolLevel
-                                                     runLoop:[NSRunLoop currentRunLoop]
+                                                     runLoop:runLoop
                                                      forMode:NSDefaultRunLoopMode
                                               securityPolicy:securityPolicy
                                                 certificates:certificates];