Skip to content

Commit 45bebf7

Browse files
committed
Give Starscream-related queues Pusher-specific names
1 parent d064eab commit 45bebf7

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

Source/PusherSwift.swift

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ let CLIENT_NAME = "pusher-websocket-swift"
4040
self.key = key
4141
let urlString = constructUrl(key: key, options: options)
4242
let ws = WebSocket(url: URL(string: urlString)!)
43+
ws.callbackQueue = DispatchQueue(label: "com.pusher.starscream.websocket.callback")
4344
connection = PusherConnection(key: key, socket: ws, url: urlString, options: options)
4445
connection.createGlobalChannel()
4546
self.nativePusher = nativePusher

Source/Starscream.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ open class WebSocket : NSObject, StreamDelegate {
436436
return canWork
437437
}
438438
/// The shared processing queue used for all WebSocket.
439-
private static let sharedWorkQueue = DispatchQueue(label: "com.vluxe.starscream.websocket", attributes: [])
439+
private static let sharedWorkQueue = DispatchQueue(label: "com.vluxe.starscream.websocket.pusher", attributes: [])
440440

441441
/// Used for setting protocols.
442442
public init(url: URL, protocols: [String]? = nil) {

0 commit comments

Comments
 (0)