fast_websocket_client 0.4.1

Tokio-native WebSocket client for Rust. High-throughput, low-latency, callback-driven, proxy-ready.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use fast_websocket_client::proxy::ProxyBuilder;
use fast_websocket_client::{ConnectionInitOptions, WebSocketBuilder};
use tokio::time::{Duration, sleep};

async fn roundtrip(opts: Option<ConnectionInitOptions>) {
    let url = "wss://echo.websocket.org";
    let ws = match opts {
        Some(o) => WebSocketBuilder::new().with_options(o).connect(url).await,
        None => WebSocketBuilder::new().connect(url).await,
    }
    .expect("could not connect");

    ws.send("hi").await.unwrap();
    sleep(Duration::from_millis(200)).await;
    ws.close().await;
    ws.await_shutdown().await;
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn direct() {
    roundtrip(None).await;
}

#[cfg(feature = "proxy")]
#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn http_proxy() {
    let proxy = ProxyBuilder::new()
        .http("http://localhost:3128")
        .unwrap()
        .build()
        .unwrap();
    roundtrip(Some(ConnectionInitOptions::new().proxy(Some(proxy)))).await;
}

#[cfg(feature = "proxy")]
#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn socks5_proxy() {
    let proxy = ProxyBuilder::new()
        .socks5("localhost:1080")
        .auth("myuser", "mypassword")
        .build()
        .unwrap();
    roundtrip(Some(ConnectionInitOptions::new().proxy(Some(proxy)))).await;
}