This commit is contained in:
parent
55289d69a3
commit
f818d64405
@ -502,6 +502,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate {
|
||||
}
|
||||
|
||||
private func parseEngineData(data: NSData) {
|
||||
Logger.log("Got binary data: %@", type: "SocketEngine", args: data)
|
||||
client?.parseBinaryData(data.subdataWithRange(NSMakeRange(1, data.length - 1)))
|
||||
}
|
||||
|
||||
|
||||
@ -54,7 +54,7 @@ public final class SocketIOClient: NSObject, SocketEngineClient {
|
||||
private var ackHandlers = SocketAckManager()
|
||||
private var currentAck = -1
|
||||
|
||||
internal var waitingData = [SocketPacket]()
|
||||
var waitingData = [SocketPacket]()
|
||||
|
||||
/**
|
||||
Create a new SocketIOClient. opts can be omitted
|
||||
|
||||
@ -156,10 +156,13 @@ class SocketParser {
|
||||
return
|
||||
}
|
||||
|
||||
let shouldExecute = socket.waitingData[0].addData(data)
|
||||
guard shouldExecute else { return }
|
||||
let shouldExecute = socket.waitingData[socket.waitingData.count - 1].addData(data)
|
||||
|
||||
var packet = socket.waitingData.removeAtIndex(0)
|
||||
guard shouldExecute else {
|
||||
return
|
||||
}
|
||||
|
||||
var packet = socket.waitingData.removeLast()
|
||||
packet.fillInPlaceholders()
|
||||
|
||||
if packet.type != .BinaryAck {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user