             print("Error while send message")
         }
     }
-
+    
     fileprivate func sendRaw(_ message: String) {
         socket.readyState == SRReadyState.OPEN ? socket.send(message) : queue.append(message)
     }
-
+    
     public func isConnected() -> Bool {
         return socket.readyState == SRReadyState.OPEN
     }
-
+    
     deinit {
         self.socket.close()
         self.socket.delegate = nil

            self.initServer(connectionParams: self.params, reconnect: self.reconnect)
        }
    }

    public required init(socket url: String) {
        socket = SRWebSocket(url: URL(string: url)!, protocols: ["graphql-ws"])
        super.init()
        socket.delegate = self
        socket.open()
    }

    fileprivate func serverMessageHandler(_ message: String) {
        if let obj = message.data(using: String.Encoding.utf8, allowLossyConversion: false) {
            do {

            sendRaw(serializedMessage)
        }
    }
    
    fileprivate func reconnectInit() {
        let unserializedMessage = InitOperationMessage(
            payload: params,
