File tree 1 file changed +7
-7
lines changed
1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -170,21 +170,21 @@ public class ACChannel {
170
170
guard let self = self else { return }
171
171
self . channelSerialQueue. async {
172
172
let message = ACSerializer . responseFrom ( stringData: text)
173
- guard message. channelName == self . channelName else { return }
174
- switch message. type {
175
- case . confirmSubscription:
173
+ let sameChannelName = message. channelName == self . channelName
174
+ switch ( message. type, sameChannelName ) {
175
+ case ( . confirmSubscription, true ) :
176
176
self . isSubscribed = true
177
177
self . executeCallback ( callbacks: self . onSubscribe, message: message)
178
178
self . flushBuffer ( )
179
- case . rejectSubscription:
179
+ case ( . rejectSubscription, true ) :
180
180
self . isSubscribed = false
181
181
self . executeCallback ( callbacks: self . onRejectSubscription, message: message)
182
- case . cancelSubscription:
182
+ case ( . cancelSubscription, true ) :
183
183
self . isSubscribed = false
184
184
self . executeCallback ( callbacks: self . onUnsubscribe, message: message)
185
- case . message:
185
+ case ( . message, true ) :
186
186
self . executeCallback ( callbacks: self . onMessage, message: message)
187
- case . ping:
187
+ case ( . ping, _ ) :
188
188
self . client? . pingRoundWatcher. ping ( )
189
189
self . executeCallback ( callbacks: self . onPing)
190
190
default : break
You can’t perform that action at this time.
0 commit comments