Struct Socket 

pub struct Socket { /* private fields */ }

One connected client.

Cheap to clone and safe to keep: sending goes through a channel, so a handle stored in a room registry does not hold the connection’s task or its buffers. Sending to a socket that has gone away is an error, not a panic.

socket.send("hello").await?;
socket.send_json(&Update { count: 3 }).await?;
socket.close().await;

Implementations

impl Socket

pub fn new( id: SocketId, path: impl Into<Arc<str>>, params: Vec<(String, String)>, outbound: UnboundedSender<Outbound>, ) -> Socket

Build a handle over outbound.

The transport owns the receiving half; a handler is only ever given this side.

pub fn id(&self) -> SocketId

This connection’s id.

pub fn path(&self) -> &str

The path it connected to.

pub fn param(&self, name: &str) -> Option<&str>

A route parameter captured from the path — rooms/{room} gives room.

pub fn parse_param<T>(&self, name: &str) -> Result<T, Error>

where T: FromStr, <T as FromStr>::Err: Display,

A route parameter, parsed.

A bad request when it will not parse: the value came from the URL the client asked for.

pub fn params(&self) -> &[(String, String)]

Every captured parameter.

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

Send a frame.

Queued rather than written: a handler that awaited the socket would block on a slow client, and one slow client must not hold up the task reading everyone else’s messages.

pub fn send_json(&self, value: &impl Serialize) -> Result<(), Error>

Send a value as a JSON text frame.

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

Close the connection.

Idempotent: closing twice is not an error, because two halves of a handler deciding to close at once is normal.

pub fn close_with(&self, reason: impl Into<String>) -> Result<(), Error>

Close with a reason the peer will see.

pub fn is_closed(&self) -> bool

Whether this handle has been asked to close, or the connection has gone.

Trait Implementations

impl Clone for Socket

fn clone(&self) -> Socket

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Socket

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

Formats the value using the given formatter.