Struct WebSocketClient 

pub struct WebSocketClient { /* private fields */ }

Implementations

impl WebSocketClient

pub fn new() -> Self

pub fn is_connected(&self) -> bool

pub fn connect( &mut self, url: String, session_cookie: &str, ) -> Result<(), WebSocketError>

pub fn reconnect(&mut self) -> Result<(), WebSocketError>

pub fn send<I: Serialize>(&mut self, message: I) -> Result<(), WebSocketError>

Sends a message over the WebSocket connection. This is a non-blocking call. If sending fails, it attempts to reconnect and resend the message. Returns an error if both attempts fail.

pub fn receive<T: DeserializeOwned>( &mut self, ) -> Result<Option<T>, WebSocketError>

Attempts to receive a message from the WebSocket. This is a non-blocking call. Returns Ok(None) if no message is available.

pub fn close(&mut self) -> Result<(), WebSocketError>

Closes the WebSocket connection gracefully. This is a non-blocking call.

pub fn wait_until_closed(&mut self) -> Result<(), WebSocketError>

Waits until the WebSocket connection is fully closed. This is a blocking call that will return once the connection is closed.

Trait Implementations

impl Default for WebSocketClient

fn default() -> WebSocketClient

Returns the “default value” for a type.

impl Drop for WebSocketClient

fn drop(&mut self)

Executes the destructor for this type.