cheykrym/socket.io-client-swift
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

wrap completion handler to run on handleQueue

Browse Source
This commit is contained in:
Andy 2018-10-02 13:47:03 +07:00
parent f9d8595a25
commit 28fad62ccd
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Source/SocketIO/Client/SocketIOClient.swift
View File

@ -295,8 +295,14 @@ open class SocketIOClient : NSObject, SocketIOClientSpec {
} }
func emit(_ data: [Any], ack: Int? = nil, binary: Bool = true, isAck: Bool = false, completion: (() -> ())? = nil) { func emit(_ data: [Any], ack: Int? = nil, binary: Bool = true, isAck: Bool = false, completion: (() -> ())? = nil) {
// wrap the completion handler so it always runs async via handlerQueue
let wrappedCompletion = {[weak self, completion] in
guard let this = self else { return }
this.manager?.handleQueue.async { completion?() }
}
guard status == .connected else { guard status == .connected else {
completion?(); wrappedCompletion();
handleClientEvent(.error, data: ["Tried emitting when not connected"]) handleClientEvent(.error, data: ["Tried emitting when not connected"])
return return
} }
@ -306,7 +312,7 @@ open class SocketIOClient : NSObject, SocketIOClientSpec {
DefaultSocketLogger.Logger.log("Emitting: \(str), Ack: \(isAck)", type: logType) DefaultSocketLogger.Logger.log("Emitting: \(str), Ack: \(isAck)", type: logType)
manager?.engine?.send(str, withData: packet.binary, completion: completion) manager?.engine?.send(str, withData: packet.binary, completion: completion != nil ? wrappedCompletion : nil)
} }
/// Call when you wish to tell the server that you've received the event for `ack`. /// Call when you wish to tell the server that you've received the event for `ack`.