Struct WebsocketConnection 

pub struct WebsocketConnection { /* private fields */ }

A WebSocket connection resource

Implementations

impl WebsocketConnection

pub fn connect( url: &str, headers: Option<&[(String, String)]>, ) -> Result<WebsocketConnection, Error>

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

impl WebsocketConnection

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

Send a message (text or binary)

impl WebsocketConnection

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

Receive the next message (blocks until available)

impl WebsocketConnection

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

Receive the next message with a timeout in milliseconds. Returns none if the timeout expires before a message arrives.

impl WebsocketConnection

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

Send a close frame with optional code and reason

impl WebsocketConnection

pub fn subscribe(&self) -> Pollable

Returns a pollable that resolves when a message is available to read

Trait Implementations

impl Debug for WebsocketConnection

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

Formats the value using the given formatter.