             sendRaw(serializedMessage)
         }
     }
-    
+
     public func subscribe(graphql query: String, variables: [String: String]?, operationName: String?, identifier: String) {
         let unserializedMessage = OperationMessage(
             payload: Payload(query: query,

            self.initServer(connectionParams: self.params, reconnect: self.reconnect)
        }
    }
    
    public required init(socket url: String, protocol graphql: String = "graphql-subscriptions") {
        socket = SRWebSocket(url: URL(string: url)!, protocols: [graphql])
        super.init()
        socket.delegate = self
        socket.open()
    }
    
    fileprivate func serverMessageHandler(_ message: String) {
        if let obj = message.data(using: String.Encoding.utf8, allowLossyConversion: false) {
            do {

            }
        }
    }

    public func initServer(connectionParams params: [String: Any]?, reconnect: Bool?) {
        if let reconnect = reconnect {
            if reconnect {
