Struct WebSocketClient 

pub struct WebSocketClient<T>
where
    T: DeserializeOwned,
{ /* private fields */ }

High-level WebSocket client with automatic reconnection, ping/pong handling, and JSON support

Implementations

impl<T> WebSocketClient<T>

where T: DeserializeOwned,

pub fn new(config: WsConnectionConfig) -> Self

Create a new WebSocket client with the given configuration

pub async fn connect(&self) -> Result<(WsWriter, WsReader)>

Connect to the WebSocket server without sending any subscription

Returns a writer and reader for manual message handling.

pub async fn connect_stream(&self) -> Result<MessageStream<T>>

Connect to the WebSocket server and return a MessageStream

The MessageStream automatically handles PING/PONG and yields parsed messages.

pub async fn connect_and_subscribe<S: Serialize>( &self, subscription: Option<&S>, ) -> Result<(WsWriter, WsReader)>

Connect and optionally send an initial subscription message

Deprecated: Use connect() + send_subscription() or connect_stream() instead.

pub async fn listen<S, F>( &self, subscription: Option<S>, handler: F, ) -> Result<()>

where S: Serialize + Clone, F: FnMut(T) -> Result<()>,

Start listening to messages with automatic reconnection and ping/pong handling

Uses exponential backoff for reconnection attempts (same config as initial connection).

Arguments

• subscription - Optional subscription message to send on each connection
• handler - Callback function that processes each received message

Example

let client = WebSocketClient::<MyMessage>::new(config);
client.listen(Some(&subscription), |msg| {
    println!("Received: {:?}", msg);
    Ok(())
}).await?;

Trait Implementations

impl<T> Clone for WebSocketClient<T>

where T: DeserializeOwned + Clone,

fn clone(&self) -> WebSocketClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.