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

            sendRaw(serializedMessage)
        }
    }

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

            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
