Struct WebSocket 

pub struct WebSocket { /* private fields */ }

An upgraded connection

Implementations

impl WebSocket

pub async fn recv(&mut self) -> Option<Result<Message>>

Next message, or None once the connection is closed (by either side, or because the peer went silent for WsOptions::idle_timeout)

Keep-alive pings are sent from inside this call, so a handler should spend most of its time waiting here (or in a select! that includes it).

pub async fn send_json<T: Serialize>(&mut self, value: &T) -> Result<()>

Send value as a JSON text message

pub async fn close_with(&mut self, code: u16, reason: &str) -> Result<()>

Close with a status code (e.g. 1008 policy violation, 1009 message too big, 1001 going away) and a short reason

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

pub async fn send_text(&mut self, text: impl Into<String>) -> Result<()>

pub async fn send_binary(&mut self, data: impl Into<Vec<u8>>) -> Result<()>

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

Start the closing handshake and flush it