     private var attemptReconnectCount = kAttemptReconnectCount
     private var connectionCompletionBlock: WebSocketConnected?
     
-    public init(url: URL,
-                queue: DispatchQueue = DispatchQueue(label:  "com.autograph.WebSocketClient", qos: .default)) throws {
-        self.queue = queue
+    public init(url: URL) throws {
         let request = try WebSocketClient.connectionRequest(url: url)
         self.webSocket = WebSocket(request: request)
         self.webSocket.delegate = self

                return
            }
            
            self.queue.async {
                self.subscribers[request.id] = responseHandler
                self.subscriptions[request.id] = subscriptionMessage
                self.write(subscriptionMessage)
            }
        }
        catch let error {
            responseHandler.didFinish(error: error)

                responseHandler.didFinish(error: error)
            }
        }
        
        guard self.state != .connected else {
            self.connectionCompletionBlock?(.success(true))
            return
        }
        
        self.webSocket.connect()
    }
    
    public func unsubscribe<R: Request>(request: SubscriptionRequest<R>) throws {
