Struct WebsocketConnection 

pub struct WebsocketConnection { /* private fields */ }

A WebSocket connection with both blocking and async receive methods.

Implementations

impl WebsocketConnection

pub fn connect( url: &str, headers: Option<Vec<(String, String)>>, ) -> Result<Self, Error>

Connect to a WebSocket server at the given URL (ws:// or wss://). Optional headers for auth, subprotocols, etc.

pub fn send(&self, message: &Message) -> Result<(), Error>

Send a message (text or binary).

pub fn blocking_receive(&self) -> Result<Message, Error>

Receive the next message, blocking until one is available.

pub fn blocking_receive_with_timeout( &self, timeout_ms: u64, ) -> Result<Option<Message>, Error>

Receive the next message, blocking with a timeout in milliseconds. Returns None if the timeout expires before a message arrives.

pub async fn receive(&self) -> Result<Message, Error>

Receive the next message asynchronously. Yields the current task until a message is available.

pub fn close( &self, code: Option<u16>, reason: Option<String>, ) -> Result<(), Error>

Send a close frame with optional code and reason.