Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

WebSocket client for connecting to Binance streams.

Implementations

impl WebSocketClient

pub fn endpoint(&self) -> &str

Get the WebSocket endpoint URL.

pub async fn connect(&self, stream: &str) -> Result<WebSocketConnection>

Connect to a single stream.

Arguments

• stream - Stream name (e.g., “btcusdt@aggTrade”)

Example

let ws = client.websocket();
let stream = ws.agg_trade_stream("btcusdt");
let mut conn = ws.connect(&stream).await?;

pub async fn connect_combined( &self, streams: &[String], ) -> Result<WebSocketConnection>

Connect to multiple streams (combined stream).

Arguments

• streams - List of stream names

Example

let ws = client.websocket();
let streams = vec![
    ws.agg_trade_stream("btcusdt"),
    ws.agg_trade_stream("ethusdt"),
];
let mut conn = ws.connect_combined(&streams).await?;

pub async fn connect_user_stream( &self, listen_key: &str, ) -> Result<WebSocketConnection>

Connect to a user data stream.

Arguments

• listen_key - Listen key obtained from user_stream().start()

Example

let listen_key = client.user_stream().start().await?;
let mut conn = client.websocket().connect_user_stream(&listen_key).await?;

pub async fn connect_with_reconnect( &self, stream: &str, ) -> Result<ReconnectingWebSocket>

Connect with auto-reconnection support.

Returns a ReconnectingWebSocket that automatically reconnects on disconnection with exponential backoff.

Arguments

• stream - Stream name (e.g., “btcusdt@aggTrade”)

Example

let ws = client.websocket();
let stream = ws.agg_trade_stream("btcusdt");
let mut conn = ws.connect_with_reconnect(&stream).await?;

// Connection will auto-reconnect on failure
while let Some(event) = conn.next().await {
    println!("{:?}", event?);
}

pub async fn connect_combined_with_reconnect( &self, streams: &[String], ) -> Result<ReconnectingWebSocket>

Connect to combined streams with auto-reconnection support.

pub fn agg_trade_stream(&self, symbol: &str) -> String

Get the aggregate trade stream name for a symbol.

Stream: <symbol>@aggTrade

pub fn trade_stream(&self, symbol: &str) -> String

Get the trade stream name for a symbol.

Stream: <symbol>@trade

pub fn kline_stream(&self, symbol: &str, interval: KlineInterval) -> String

Get the kline/candlestick stream name for a symbol.

Stream: <symbol>@kline_<interval>

pub fn mini_ticker_stream(&self, symbol: &str) -> String

Get the mini ticker stream name for a symbol.

Stream: <symbol>@miniTicker

pub fn all_mini_ticker_stream(&self) -> String

Get the mini ticker stream for all symbols.

Stream: !miniTicker@arr

pub fn ticker_stream(&self, symbol: &str) -> String

Get the 24hr ticker stream name for a symbol.

Stream: <symbol>@ticker

pub fn all_ticker_stream(&self) -> String

Get the 24hr ticker stream for all symbols.

Stream: !ticker@arr

pub fn book_ticker_stream(&self, symbol: &str) -> String

Get the book ticker stream name for a symbol.

Stream: <symbol>@bookTicker

pub fn all_book_ticker_stream(&self) -> String

Get the book ticker stream for all symbols.

Stream: !bookTicker

pub fn partial_depth_stream( &self, symbol: &str, levels: u8, fast: bool, ) -> String

Get the partial book depth stream name.

Stream: <symbol>@depth<levels> or <symbol>@depth<levels>@100ms

Arguments

• symbol - Trading pair symbol
• levels - Depth levels (5, 10, or 20)
• fast - If true, use 100ms update speed instead of 1000ms

pub fn diff_depth_stream(&self, symbol: &str, fast: bool) -> String

Get the diff depth stream name.

Stream: <symbol>@depth or <symbol>@depth@100ms

Arguments

• symbol - Trading pair symbol
• fast - If true, use 100ms update speed instead of 1000ms

Trait Implementations

impl Clone for WebSocketClient

fn clone(&self) -> WebSocketClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.