From 1f05bde09bf88cd74d6db3600f44065d548a2c4c Mon Sep 17 00:00:00 2001 From: Erik Date: Fri, 13 Mar 2015 09:09:37 -0400 Subject: [PATCH] small tweaks --- SwiftIO/SocketEngine.swift | 6 +----- SwiftIO/SocketEvent.swift | 2 +- SwiftIO/SocketIOClient.swift | 10 ++++++---- SwiftIO/SocketParser.swift | 5 ++--- 4 files changed, 10 insertions(+), 13 deletions(-) diff --git a/SwiftIO/SocketEngine.swift b/SwiftIO/SocketEngine.swift index f3fd854..ded5f53 100644 --- a/SwiftIO/SocketEngine.swift +++ b/SwiftIO/SocketEngine.swift @@ -180,8 +180,6 @@ public class SocketEngine: NSObject, WebSocketDelegate { if let str = NSString(data: data, encoding: NSUTF8StringEncoding) as? String { // println(str) - - dispatch_async(self!.parseQueue) {callback(str)} } @@ -196,8 +194,6 @@ public class SocketEngine: NSObject, WebSocketDelegate { }.resume() } - - private func flushProbeWait() { // println("flushing probe wait") dispatch_async(self.emitQueue) {[weak self] in @@ -464,7 +460,7 @@ public class SocketEngine: NSObject, WebSocketDelegate { } } - func send(msg:String, datas:[NSData]? = nil) { + public func send(msg:String, datas:[NSData]? = nil) { let _send = {[weak self] (msg:String, datas:[NSData]?) -> () -> Void in return { if self == nil || !self!.connected { diff --git a/SwiftIO/SocketEvent.swift b/SwiftIO/SocketEvent.swift index 7f5f133..f7b6080 100644 --- a/SwiftIO/SocketEvent.swift +++ b/SwiftIO/SocketEvent.swift @@ -226,7 +226,7 @@ class SocketEvent { // We have multiple items // Do it live let argsAsArray = "[\(self.args)]" - if let parsedArr = SocketIOClient.parseData(argsAsArray) as? NSArray { + if let parsedArr = SocketParser.parseData(argsAsArray) as? NSArray { var returnArr = [AnyObject](count: parsedArr.count, repeatedValue: 0) for i in 0.. self.reconnectAttempts { self.didForceClose() return diff --git a/SwiftIO/SocketParser.swift b/SwiftIO/SocketParser.swift index 5fcb541..cc685f6 100644 --- a/SwiftIO/SocketParser.swift +++ b/SwiftIO/SocketParser.swift @@ -202,8 +202,6 @@ class SocketParser { socket.joinNamespace() return } else { - // Don't handle as internal because something crazy could happen where - // we disconnect before it's handled socket.didConnect() return } @@ -225,7 +223,8 @@ class SocketParser { if messageGroups[3] != "" { ackNum = messageGroups[3] } else { - let range = Range(start: mesNum.startIndex, end: advance(mesNum.startIndex, 1)) + let range = Range(start: mesNum.startIndex, + end: advance(mesNum.startIndex, 1)) mesNum.replaceRange(range, with: "") ackNum = mesNum }