Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

Async WebSocket client — manages connection lifecycle and reconnection (BR-006, BR-007).

Implementations

impl WebSocketClient

pub fn new(base_url: &str) -> Result<Self, AsterDexError>

Construct a new WebSocket client.

pub fn with_reconnect_config(self, cfg: ReconnectConfig) -> Self

Builder method: set a custom reconnect configuration.

pub async fn subscribe( &self, streams: Vec<&str>, ) -> Result<WebSocketStream, AsterDexError>

Subscribe to market data streams (combined stream endpoint).

Errors

• WebSocketError("at least one stream name required") if streams is empty.
• WebSocketError("max 200 streams per connection") if > 200 streams.
• WebSocketError("connection failed: …") if the initial connection fails.

pub async fn unsubscribe( _stream: &mut WebSocketStream, _streams: Vec<&str>, ) -> Result<(), AsterDexError>

Unsubscribe from specific streams on an active connection.

Not yet supported — drop the WebSocketStream to close the connection.

pub async fn subscribe_user_data( &self, listen_key: &str, ) -> Result<UserDataStream, AsterDexError>

Subscribe to the user data stream using a listen key.

Errors

• WebSocketError("user data stream connection failed: …") if the initial connection fails.

Trait Implementations

impl Debug for WebSocketClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.