Struct ReliableWebSocketSession 

pub struct ReliableWebSocketSession { /* private fields */ }

Enhanced WebSocket session with reliability features

Implementations

impl ReliableWebSocketSession

pub fn new(url: String, config: WebSocketReliabilityConfig) -> Self

Create a new reliable WebSocket session

pub async fn connect_reliable(&self) -> Result<()>

Connect with reliability features

Errors

Returns an error if the WebSocket connection cannot be established after the maximum number of reconnection attempts, or if the connection times out.

Panics

Panics if the internal mutex for tracking connection state is poisoned.

pub async fn send_event_reliable( &self, event: RealtimeClientEvent, ) -> Result<()>

Send an event with reliability guarantees

Errors

Returns an error if the event cannot be sent due to connection failures, serialization issues, or if the maximum reconnection attempts are exceeded.

Panics

Panics if the internal mutex for message buffering is poisoned.

pub async fn recv_event_reliable(&self) -> Result<RealtimeServerEvent>

Receive an event from the WebSocket

Errors

Returns an error if no event can be received due to connection failures, WebSocket errors, or if no active connection exists.

pub async fn get_connection_state(&self) -> ConnectionState

Get current connection state

pub async fn is_connection_healthy(&self) -> bool

Check if connection is healthy

Panics

Panics if the internal mutex for last heartbeat tracking is poisoned.

pub async fn get_stats(&self) -> WebSocketConnectionStats

Get connection statistics

pub fn get_buffered_message_count(&self) -> usize

Get buffered message count

Panics

This function will panic if the message buffer mutex is poisoned.

pub async fn flush_message_buffer(&self) -> Result<usize>

Flush message buffer and attempt to send all messages

Errors

This function returns an error if the WebSocket session fails to send messages.

Panics

This function will panic if the message buffer mutex is poisoned.

pub async fn close(&self) -> Result<()>

Close the connection gracefully

Errors

This function returns an error if the connection cannot be closed properly.

Trait Implementations

impl Debug for ReliableWebSocketSession

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

Formats the value using the given formatter.

impl Drop for ReliableWebSocketSession

fn drop(&mut self)

Executes the destructor for this type.