Struct WsClient 

pub struct WsClient {
    pub url: String,
    pub state: WsState,
    pub auto_reconnect: bool,
    pub max_reconnects: u32,
    pub ping_interval: Duration,
    pub pong_timeout: Duration,
    pub max_queue_size: usize,
    /* private fields */
}

WebSocket client driven by tick().

Fields

url: String

state: WsState

auto_reconnect: bool

Auto-reconnect on unexpected disconnect.

max_reconnects: u32

Max reconnect attempts before giving up (0 = unlimited).

ping_interval: Duration

Keepalive ping interval.

pong_timeout: Duration

Close connection if no pong received within this time.

max_queue_size: usize

Max size of outbound queue.

Implementations

impl WsClient

pub fn new(url: impl Into<String>) -> Self

pub fn connect(&mut self)

Initiate a connection. No-op if already connected.

pub fn close(&mut self)

Close the connection intentionally (will not auto-reconnect).

pub fn disconnect(&mut self)

Disconnect but allow auto-reconnect.

pub fn send(&mut self, message: WsMessage) -> bool

Send a message. Queued if not currently connected.

pub fn send_on_channel(&mut self, channel: &str, message: WsMessage) -> bool

Send a message on a named channel.

pub fn subscribe(&mut self, channel: impl Into<String>)

Subscribe to a named logical channel.

pub fn unsubscribe(&mut self, channel: &str)

pub fn tick(&mut self, dt: f32)

Drive the WebSocket state machine. Call once per frame.

pub fn drain_events(&mut self) -> impl Iterator<Item = WsEvent> + '_

pub fn is_connected(&self) -> bool

pub fn messages_sent(&self) -> u64

pub fn messages_received(&self) -> u64

pub fn bytes_sent(&self) -> u64

pub fn bytes_received(&self) -> u64

pub fn uptime(&self) -> Option<Duration>

pub fn pending_outbound(&self) -> usize