Skip to content

Commit 838dade

Browse files
committed
Fix messages getting stuck in post
1 parent d4470a9 commit 838dade

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

SwiftIO/SocketEngine.swift

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -171,14 +171,12 @@ public class SocketEngine: NSObject, WebSocketDelegate {
171171
}
172172

173173
private func doFastUpgrade() {
174-
dispatch_async(self.emitQueue) {[weak self] in
175-
self?.sendWebSocketMessage("", withType: PacketType.UPGRADE)
176-
self?._websocket = true
177-
self?._polling = false
178-
self?.fastUpgrade = false
179-
self?.probing = false
180-
self?.flushProbeWait()
181-
}
174+
self.sendWebSocketMessage("", withType: PacketType.UPGRADE)
175+
self._websocket = true
176+
self._polling = false
177+
self.fastUpgrade = false
178+
self.probing = false
179+
self.flushProbeWait()
182180
}
183181

184182
private func doPoll() {
@@ -243,7 +241,10 @@ public class SocketEngine: NSObject, WebSocketDelegate {
243241
}
244242

245243
self?.probeWait.removeAll(keepCapacity: false)
246-
// NSLog("waiting for post after flush probe: \(self!.postWait.count)")
244+
245+
if self?.postWait.count != 0 {
246+
self?.flushWaitingForPostToWebSocket()
247+
}
247248
}
248249
}
249250

0 commit comments

Comments
 (0)