Struct WsClient 

pub struct WsClient { /* private fields */ }

A cheap, clonable handle to one connected client.

Passed to every gateway lifecycle hook and #[Subscribe] handler. All methods are non-blocking and lock-free on the hot path: emitting just enqueues onto a sharded channel. Holds a &'static ConnectionRegistry, so cloning is a pointer copy — no Arc refcount traffic for the registry.

Implementations

impl WsClient

pub fn id(&self) -> ConnId

This connection’s unique id.

pub fn claims(&self) -> Option<&Claims>

Session claims captured during the handshake (e.g. decoded JWT), if any.

pub fn tenant(&self) -> Option<&TenantConfig>

The tenant resolved during the handshake — same registry, strategy, and suspension semantics as HTTP requests. Gateways enforce multi-tenancy with this exactly like controllers use ctx.tenant().

pub async fn emit<T: Serialize>(&self, event: &str, payload: T)

Send an event to this client only.

pub async fn broadcast<T: Serialize>(&self, event: &str, payload: T)

Broadcast an event to every connected client (including self).

pub async fn broadcast_to_room<T: Serialize>( &self, room: &str, event: &str, payload: T, )

Broadcast an event to every client currently in room.

pub fn join_room(&self, room: impl Into<String>)

Join a logical room/channel. Subsequent room broadcasts reach this client.

pub fn leave_room(&self, room: &str)

Leave a room.

Trait Implementations

impl Clone for WsClient

fn clone(&self) -> WsClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.