Struct Sender 

pub struct Sender { /* private fields */ }

A cloneable handle for pushing messages at one client.

Handed to the broadcaster, to background tasks, to anything that produces events. It never blocks the reader, and it can outlive the socket: once the connection is gone every clone reports closed.

Implementations

impl Sender

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

Queue a message, waiting for room. Use this from the connection’s own task, where waiting is what you want.

pub fn try_send(&self, message: impl Into<Message>) -> WsResult<()>

Queue a message only if there is room right now.

This is the shape broadcasting needs: fan-out must never wait on the slowest subscriber, so a full queue is a failure the caller acts on by dropping the subscriber.

pub fn is_closed(&self) -> bool

pub fn room(&self) -> usize

How many more messages fit before this client counts as too slow.

Trait Implementations

impl Clone for Sender

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.