Module ws 

WebSocket module for Bybit V5 real-time data streams.

Provides connection management, authentication, and typed data structures for all Bybit WebSocket channels.

Quick Start

use bybit_rust_api::ws::{WsClient, topics};
use futures_util::StreamExt;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let client = WsClient::connect(
        "wss://stream.bybit.com/v5/public/linear"
    ).await?;

    client.subscribe(vec![
        topics::orderbook(1, "BTCUSDT"),
        topics::trade("BTCUSDT"),
        topics::kline("1", "BTCUSDT"),
    ]).await?;

    while let Some(msg) = client.next().await {
        println!("Topic: {:?}", msg.topic());
    }
    Ok(())
}

Re-exports

pub use auth::generate_auth_params;

pub use client::WsClient;

pub use messages::topics;

pub use messages::WsMessage;

pub use messages::WsOpResponse;

pub use messages::WsRequest;

pub use messages::WsResponse;

Modules

auth

WebSocket authentication for Bybit V5 private channels.

client

WebSocket client for Bybit V5 with automatic reconnection and resubscription.

messages

WebSocket message types for Bybit V5 WebSocket API.

private

Private WebSocket channel implementations.

public

Public WebSocket channel implementations.

trade

WebSocket Trade (Order Entry) — place, amend, cancel orders via WebSocket.