diff --git a/Source/ARTRealtime.m b/Source/ARTRealtime.m index 67fec3404..dfe75db0e 100644 --- a/Source/ARTRealtime.m +++ b/Source/ARTRealtime.m @@ -430,7 +430,7 @@ - (void)connect { } - (void)_connect { - if(self.connection.state_nosync == ARTRealtimeClosing) { + if (self.connection.state_nosync == ARTRealtimeClosing) { // New connection _transport = nil; } @@ -1314,7 +1314,7 @@ - (void)send:(ARTProtocolMessage *)msg sentCallback:(ARTCallback)sentCallback ac [self send:msg reuseMsgSerial:NO sentCallback:sentCallback ackCallback:ackCallback]; } -- (void)resendPendingMessagesWithResumed:(BOOL)reuseMsgSerial { +- (void)resendPendingMessagesWithResumed:(BOOL)resumed { NSArray *pendingMessages = self.pendingMessages; if (pendingMessages.count > 0) { ARTLogDebug(self.logger, @"RT:%p resending messages waiting for acknowledgment", self); @@ -1322,7 +1322,7 @@ - (void)resendPendingMessagesWithResumed:(BOOL)reuseMsgSerial { self.pendingMessages = [NSMutableArray array]; for (ARTPendingMessage *pendingMessage in pendingMessages) { ARTProtocolMessage* pm = pendingMessage.msg; - [self send:pm reuseMsgSerial:reuseMsgSerial sentCallback:nil ackCallback:^(ARTStatus *status) { + [self send:pm reuseMsgSerial:resumed sentCallback:nil ackCallback:^(ARTStatus *status) { pendingMessage.ackCallback(status); }]; }