@@ -67,7 +67,7 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
67
67
return nsp + " # " + ( engine? . sid ?? " " )
68
68
}
69
69
70
- /// Type safe way to create a new SocketIOClient. opts can be omitted
70
+ /// Type safe way to create a new SocketIOClient. config can be omitted
71
71
public init ( socketURL: NSURL , config: SocketIOClientConfiguration = [ ] ) {
72
72
self . config = config
73
73
self . socketURL = socketURL
@@ -150,33 +150,33 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
150
150
let time = dispatch_time ( DISPATCH_TIME_NOW, Int64 ( timeoutAfter) * Int64( NSEC_PER_SEC) )
151
151
152
152
dispatch_after ( time, handleQueue) { [ weak self] in
153
- if let this = self where this. status != . Connected && this. status != . Disconnected {
154
- this . status = . Disconnected
155
- this. engine ? . disconnect ( " Connect timeout " )
156
-
157
- handler ? ( )
158
- }
153
+ guard let this = self where this. status != . Connected && this. status != . Disconnected else { return }
154
+
155
+ this. status = . Disconnected
156
+ this . engine ? . disconnect ( " Connect timeout " )
157
+
158
+ handler ? ( )
159
159
}
160
160
}
161
161
162
162
private func createOnAck( items: [ AnyObject ] ) -> OnAckCallback {
163
163
currentAck += 1
164
164
165
165
return { [ weak self, ack = currentAck] timeout, callback in
166
- if let this = self {
167
- dispatch_sync ( this. ackQueue) {
168
- this. ackHandlers. addAck ( ack, callback: callback)
169
- }
170
-
166
+ guard let this = self else { return }
167
+
168
+ dispatch_sync ( this. ackQueue) {
169
+ this. ackHandlers. addAck ( ack, callback: callback)
170
+ }
171
+
172
+
173
+ this. _emit ( items, ack: ack)
174
+
175
+ if timeout != 0 {
176
+ let time = dispatch_time ( DISPATCH_TIME_NOW, Int64 ( timeout * NSEC_PER_SEC) )
171
177
172
- this. _emit ( items, ack: ack)
173
-
174
- if timeout != 0 {
175
- let time = dispatch_time ( DISPATCH_TIME_NOW, Int64 ( timeout * NSEC_PER_SEC) )
176
-
177
- dispatch_after ( time, this. ackQueue) {
178
- this. ackHandlers. timeoutAck ( ack, onQueue: this. handleQueue)
179
- }
178
+ dispatch_after ( time, this. ackQueue) {
179
+ this. ackHandlers. timeoutAck ( ack, onQueue: this. handleQueue)
180
180
}
181
181
}
182
182
}
@@ -196,6 +196,7 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
196
196
197
197
DefaultSocketLogger . Logger. log ( " Disconnected: %@ " , type: logType, args: reason)
198
198
199
+ reconnecting = false
199
200
status = . Disconnected
200
201
201
202
// Make sure the engine is actually dead.
@@ -205,8 +206,6 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
205
206
206
207
/// Disconnects the socket.
207
208
public func disconnect( ) {
208
- assert ( status != . NotConnected, " Tried closing a NotConnected client " )
209
-
210
209
DefaultSocketLogger . Logger. log ( " Closing socket " , type: logType)
211
210
212
211
didDisconnect ( " Disconnect " )
0 commit comments