test-query-data 0.1.3

This crate is only for testing not for production use.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use tokio::net::TcpStream;
use tokio_tungstenite::{MaybeTlsStream, WebSocketStream};

pub struct WebSocketQuerier {
    url: String,
    socket: Option<WebSocketStream<MaybeTlsStream<TcpStream>>>,
}

impl WebSocketQuerier {
    pub fn new(url: String) -> Self {
        Self { url, socket: None }
    }

    pub async fn connect(
        &mut self,
        path: &str,
    ) -> Result<(), tokio_tungstenite::tungstenite::Error> {
        let url = format!("{}{}", self.url, path);
        let (socket, _) = tokio_tungstenite::connect_async(url).await?;
        self.socket = Some(socket);
        Ok(())
    }
}