add test
This commit is contained in:
parent
51ee4d3d1d
commit
c6d000972e
@ -137,6 +137,12 @@ class SocketSideEffectTest: XCTestCase {
|
|||||||
waitForExpectations(withTimeout: 3, handler: nil)
|
waitForExpectations(withTimeout: 3, handler: nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func testSocketDataToAnyObject() {
|
||||||
|
let data = ["test", 1, 2.2, ["Hello": 2, "bob": 2.2], true, [1, 2], [1.1, 2]] as [SocketData]
|
||||||
|
|
||||||
|
XCTAssertEqual(data.count, socket.socketDataToAnyObject(data: data).count)
|
||||||
|
}
|
||||||
|
|
||||||
func testHandleMultipleBinaryEvent() {
|
func testHandleMultipleBinaryEvent() {
|
||||||
let expect = expectation(withDescription: "handled multiple binary event")
|
let expect = expectation(withDescription: "handled multiple binary event")
|
||||||
socket.on("test") {data, ack in
|
socket.on("test") {data, ack in
|
||||||
|
|||||||
@ -405,6 +405,10 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
|
|||||||
public func removeAllHandlers() {
|
public func removeAllHandlers() {
|
||||||
handlers.removeAll(keepingCapacity: false)
|
handlers.removeAll(keepingCapacity: false)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func socketDataToAnyObject(data: [SocketData]) -> [AnyObject] {
|
||||||
|
return data.flatMap({$0 as? AnyObject})
|
||||||
|
}
|
||||||
|
|
||||||
private func tryReconnect(reason: String) {
|
private func tryReconnect(reason: String) {
|
||||||
if reconnecting {
|
if reconnecting {
|
||||||
|
|||||||
@ -40,8 +40,4 @@ extension SocketIOClientSpec {
|
|||||||
|
|
||||||
handleEvent("error", data: [reason as AnyObject], isInternalMessage: true, withAck: -1)
|
handleEvent("error", data: [reason as AnyObject], isInternalMessage: true, withAck: -1)
|
||||||
}
|
}
|
||||||
|
|
||||||
func socketDataToAnyObject(data: [SocketData]) -> [AnyObject] {
|
|
||||||
return data.flatMap({$0 as? AnyObject})
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user