1.2 fixes single statement closures
This commit is contained in:
parent
076bbfc782
commit
0588556c17
@ -39,7 +39,6 @@ struct SocketAckMap {
|
|||||||
|
|
||||||
dispatch_async(dispatch_get_main_queue()) {
|
dispatch_async(dispatch_get_main_queue()) {
|
||||||
callback?(items)
|
callback?(items)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
acks.removeValueForKey(ack)
|
acks.removeValueForKey(ack)
|
||||||
|
|||||||
@ -230,7 +230,6 @@ public class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
if let str = NSString(data: data, encoding: NSUTF8StringEncoding) as? String {
|
if let str = NSString(data: data, encoding: NSUTF8StringEncoding) as? String {
|
||||||
dispatch_async(self!.parseQueue) {
|
dispatch_async(self!.parseQueue) {
|
||||||
self?.parsePollingMessage(str)
|
self?.parsePollingMessage(str)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -423,7 +422,6 @@ public class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
// Be sure to capture the value of the msg
|
// Be sure to capture the value of the msg
|
||||||
dispatch_async(self.handleQueue) {[weak self, msg] in
|
dispatch_async(self.handleQueue) {[weak self, msg] in
|
||||||
self?.parseEngineMessage(msg, fromPolling: true)
|
self?.parseEngineMessage(msg, fromPolling: true)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -440,7 +438,6 @@ public class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
|
|
||||||
dispatch_async(self.client!.handleQueue) {[weak self] in
|
dispatch_async(self.client!.handleQueue) {[weak self] in
|
||||||
self?.client?.parseBinaryData(data.subdataWithRange(NSMakeRange(1, data.length - 1)))
|
self?.client?.parseBinaryData(data.subdataWithRange(NSMakeRange(1, data.length - 1)))
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -462,7 +459,6 @@ public class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
|
|
||||||
dispatch_async(self.client!.handleQueue) {[weak self] in
|
dispatch_async(self.client!.handleQueue) {[weak self] in
|
||||||
self?.client?.parseSocketMessage(message)
|
self?.client?.parseSocketMessage(message)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
} else if type == PacketType.NOOP {
|
} else if type == PacketType.NOOP {
|
||||||
self.doPoll()
|
self.doPoll()
|
||||||
@ -533,7 +529,6 @@ public class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
|
|
||||||
dispatch_async(self.client!.handleQueue) {[weak self] in
|
dispatch_async(self.client!.handleQueue) {[weak self] in
|
||||||
self?.client?.parseBinaryData(data)
|
self?.client?.parseBinaryData(data)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -43,7 +43,6 @@ class SocketEventHandler {
|
|||||||
withSocket socket:SocketIOClient? = nil) {
|
withSocket socket:SocketIOClient? = nil) {
|
||||||
dispatch_async(dispatch_get_main_queue()) {[weak self] in
|
dispatch_async(dispatch_get_main_queue()) {[weak self] in
|
||||||
self?.callback?(items, ack != nil ? emitAckCallback(socket!, ack!) : nil)
|
self?.callback?(items, ack != nil ? emitAckCallback(socket!, ack!) : nil)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -199,7 +199,6 @@ public class SocketIOClient: NSObject, SocketEngineClient {
|
|||||||
|
|
||||||
dispatch_async(self!.emitQueue) {
|
dispatch_async(self!.emitQueue) {
|
||||||
self?._emit(event, items, ack: ack)
|
self?._emit(event, items, ack: ack)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if timeout != 0 {
|
if timeout != 0 {
|
||||||
@ -207,7 +206,6 @@ public class SocketIOClient: NSObject, SocketEngineClient {
|
|||||||
|
|
||||||
dispatch_after(time, dispatch_get_main_queue()) {
|
dispatch_after(time, dispatch_get_main_queue()) {
|
||||||
self?.ackHandlers.timeoutAck(ack)
|
self?.ackHandlers.timeoutAck(ack)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -259,7 +257,6 @@ public class SocketIOClient: NSObject, SocketEngineClient {
|
|||||||
|
|
||||||
dispatch_async(self.emitQueue) {[weak self] in
|
dispatch_async(self.emitQueue) {[weak self] in
|
||||||
self?._emit(event, items)
|
self?._emit(event, items)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -273,7 +270,6 @@ public class SocketIOClient: NSObject, SocketEngineClient {
|
|||||||
|
|
||||||
dispatch_async(self.emitQueue) {[weak self] in
|
dispatch_async(self.emitQueue) {[weak self] in
|
||||||
self?._emit(event, items)
|
self?._emit(event, items)
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -365,7 +361,6 @@ public class SocketIOClient: NSObject, SocketEngineClient {
|
|||||||
if self.anyHandler != nil {
|
if self.anyHandler != nil {
|
||||||
dispatch_async(dispatch_get_main_queue()) {[weak self] in
|
dispatch_async(dispatch_get_main_queue()) {[weak self] in
|
||||||
self?.anyHandler?(SocketAnyEvent(event: event, items: data))
|
self?.anyHandler?(SocketAnyEvent(event: event, items: data))
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user