commit
259b453acb
@ -35,7 +35,7 @@ private struct SocketAck : Hashable {
|
||||
self.ack = ack
|
||||
}
|
||||
|
||||
init(ack: Int, callback: AckCallback) {
|
||||
init(ack: Int, callback: @escaping AckCallback) {
|
||||
self.ack = ack
|
||||
self.callback = callback
|
||||
}
|
||||
@ -52,7 +52,7 @@ private func ==(lhs: SocketAck, rhs: SocketAck) -> Bool {
|
||||
struct SocketAckManager {
|
||||
private var acks = Set<SocketAck>(minimumCapacity: 1)
|
||||
|
||||
mutating func addAck(_ ack: Int, callback: AckCallback) {
|
||||
mutating func addAck(_ ack: Int, callback: @escaping AckCallback) {
|
||||
acks.insert(SocketAck(ack: ack, callback: callback))
|
||||
}
|
||||
|
||||
|
||||
@ -355,7 +355,7 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
|
||||
/// Adds a handler for an event.
|
||||
/// Returns: A unique id for the handler
|
||||
@discardableResult
|
||||
public func on(_ event: String, callback: NormalCallback) -> UUID {
|
||||
public func on(_ event: String, callback: @escaping NormalCallback) -> UUID {
|
||||
DefaultSocketLogger.Logger.log("Adding handler for event: %@", type: logType, args: event)
|
||||
|
||||
let handler = SocketEventHandler(event: event, id: UUID(), callback: callback)
|
||||
@ -367,7 +367,7 @@ public final class SocketIOClient : NSObject, SocketEngineClient, SocketParsable
|
||||
/// Adds a single-use handler for an event.
|
||||
/// Returns: A unique id for the handler
|
||||
@discardableResult
|
||||
public func once(_ event: String, callback: NormalCallback) -> UUID {
|
||||
public func once(_ event: String, callback: @escaping NormalCallback) -> UUID {
|
||||
DefaultSocketLogger.Logger.log("Adding once handler for event: %@", type: logType, args: event)
|
||||
|
||||
let id = UUID()
|
||||
|
||||
@ -41,7 +41,7 @@ extension String : SocketData {}
|
||||
|
||||
public typealias AckCallback = ([Any]) -> Void
|
||||
public typealias NormalCallback = ([Any], SocketAckEmitter) -> Void
|
||||
public typealias OnAckCallback = (_ timeoutAfter: UInt64, _ callback: AckCallback) -> Void
|
||||
public typealias OnAckCallback = (_ timeoutAfter: UInt64, _ callback: @escaping AckCallback) -> Void
|
||||
|
||||
typealias Probe = (msg: String, type: SocketEnginePacketType, data: [Data])
|
||||
typealias ProbeWaitQueue = [Probe]
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user