fast_websocket_client

Tokio-native WebSocket client for Rust – high-throughput, low-latency, callback-driven, proxy-ready.

Supports two modes of operation:

• High-level callback-based client for ergonomic event-driven use.
• Low-level direct API for fine-tuned control with minimal dependencies.

Quick Example: examples/async_callback_client.rs

Features

• JavaScript-like callback API for event handling
• Async/await support via tokio
• Powered by fastwebsockets
• Built-in reconnection and ping loop
• TLS support
• Custom HTTP headers for handshake (e.g., Authorization)
• Proxy support (HTTP CONNECT & SOCKS5)

Installation

cargo add fast_websocket_client

High-Level Callback API

An ergonomic, JavaScript-like API with built-in reconnect, ping, and lifecycle hooks.

// try this example with
// `cargo run --example wss_client`

use tokio::time::{Duration, sleep};
use fast_websocket_client::WebSocket;

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), fast_websocket_client::WebSocketClientError> {
    let ws = WebSocket::new("wss://echo.websocket.org").await?;

    ws.on_open(|_| async move {
        println!("[OPEN] WebSocket connection opened.");
    })
    .await;
    ws.on_close(|_| async move {
        println!("[CLOSE] WebSocket connection closed.");
    })
    .await;
    ws.on_message(|message| async move {
        println!("[MESSAGE] {}", message);
    })
    .await;

    sleep(Duration::from_secs(2)).await;
    for i in 1..5 {
        let message = format!("#{}", i);
        if let Err(e) = ws.send(&message).await {
            eprintln!("[ERROR] Send error: {:?}", e);
            break;
        }
        println!("[SEND] {}", message);
        sleep(Duration::from_secs(2)).await;
    }

    ws.close().await;
    ws.await_shutdown().await;
    Ok(())
}

Low-Level API

use fast_websocket_client::{connect, OpCode};

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let mut client = connect("wss://echo.websocket.org").await?;

    client.send_string("Hello, WebSocket!").await?;

    let frame = client.receive_frame().await?;
    if frame.opcode == OpCode::Text {
        println!("Received: {}", String::from_utf8_lossy(&frame.payload));
    }

    client.send_close("bye").await?;
    Ok(())
}

Running the Example

Clone the repo and run:

cargo run --example wss_client

Migration Guide (from 0.2.0)

New users: We recommend starting with the WebSocket API for best experience.

Documentation

• docs.rs/fast_websocket_client
• Examples
• fastwebsockets upstream

💡 Actively maintained - contributions are welcome!