Skip to content

Commit

Permalink
Typos fixed.
Browse files Browse the repository at this point in the history
  • Loading branch information
maratal committed Feb 23, 2024
1 parent 09d399b commit c7294f9
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions Source/ARTRealtime.m
Original file line number Diff line number Diff line change
Expand Up @@ -430,7 +430,7 @@ - (void)connect {
}

- (void)_connect {
if(self.connection.state_nosync == ARTRealtimeClosing) {
if (self.connection.state_nosync == ARTRealtimeClosing) {
// New connection
_transport = nil;
}
Expand Down Expand Up @@ -1314,15 +1314,15 @@ - (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<ARTPendingMessage *> *pendingMessages = self.pendingMessages;
if (pendingMessages.count > 0) {
ARTLogDebug(self.logger, @"RT:%p resending messages waiting for acknowledgment", self);
}
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);
}];
}
Expand Down

0 comments on commit c7294f9

Please sign in to comment.