fix race condition

This commit is contained in:
Erik 2015-03-19 14:13:03 -04:00
parent 72d5c07de1
commit cbc59d6004

View File

@ -557,16 +557,22 @@ public class SocketEngine: NSObject, WebSocketDelegate {
}
public func write(msg:String, withType type:PacketType, withData data:[NSData]?) {
if !self.connected {
return
}
dispatch_async(self.emitQueue) {[weak self] in
if self == nil {
return
}
if self.websocket {
// NSLog("writing ws: \(msg):\(datas)")
self.sendWebSocketMessage(msg, withType: type, datas: data)
} else {
// NSLog("writing poll: \(msg):\(datas)")
self.sendPollMessage(msg, withType: type, datas: data)
if !self!.connected {
return
}
if self!.websocket {
// NSLog("writing ws: \(msg):\(datas)")
self?.sendWebSocketMessage(msg, withType: type, datas: data)
} else {
// NSLog("writing poll: \(msg):\(datas)")
self?.sendPollMessage(msg, withType: type, datas: data)
}
}
}