tweaks to socketengine
This commit is contained in:
parent
4ae6489230
commit
0eeecd84ce
@ -188,7 +188,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
return (urlPolling, urlWebSocket)
|
return (urlPolling, urlWebSocket)
|
||||||
}
|
}
|
||||||
|
|
||||||
private func createWebsocket(andConnect connect: Bool) {
|
private func createWebsocketAndConnect(connect: Bool) {
|
||||||
let wsUrl = urlWebSocket + (sid == "" ? "" : "&sid=\(sid)")
|
let wsUrl = urlWebSocket + (sid == "" ? "" : "&sid=\(sid)")
|
||||||
|
|
||||||
ws = WebSocket(url: NSURL(string: wsUrl)!,
|
ws = WebSocket(url: NSURL(string: wsUrl)!,
|
||||||
@ -408,7 +408,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if !forcePolling && !forceWebsockets && upgradeWs {
|
if !forcePolling && !forceWebsockets && upgradeWs {
|
||||||
createWebsocket(andConnect: true)
|
createWebsocketAndConnect(true)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch {
|
} catch {
|
||||||
@ -464,7 +464,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
if forceWebsockets {
|
if forceWebsockets {
|
||||||
polling = false
|
polling = false
|
||||||
websocket = true
|
websocket = true
|
||||||
createWebsocket(andConnect: true)
|
createWebsocketAndConnect(true)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -620,7 +620,7 @@ public final class SocketEngine: NSObject, WebSocketDelegate {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func stopPolling() {
|
func stopPolling() {
|
||||||
session.invalidateAndCancel()
|
session.finishTasksAndInvalidate()
|
||||||
}
|
}
|
||||||
|
|
||||||
private func upgradeTransport() {
|
private func upgradeTransport() {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user