Struct WsHub 

pub struct WsHub<T: Clone + Send + 'static> { /* private fields */ }

Hub that fans messages out to every connected WebSocket. Cheap to clone — internally an Arc<broadcast::Sender> plus config.

Implementations

impl<T: Clone + Send + Serialize + 'static> WsHub<T>

pub fn new(bus: EventBus<T>) -> Self

pub fn with_config(bus: EventBus<T>, config: WsConfig) -> Self

pub fn keepalive(self, interval: Duration) -> Self

Override the keepalive interval. Lower = better dead-connection detection, higher = less network chatter. Default: 30 seconds.

pub fn on_message(self, f: fn(&str) -> Option<String>) -> Self

Set a per-message text handler. Returning Some(reply) echoes back to the originating client only (NOT a broadcast). Use the hub’s Self::broadcast for fan-out from the handler if needed.

pub fn max_message_bytes(self, n: usize) -> Self

pub fn broadcast(&self, event: T) -> usize

Send event to every currently connected client. Drops with no effect when zero clients are connected. Returns the number of receivers that observed the send.

pub fn receiver_count(&self) -> usize

pub fn bus(&self) -> &EventBus<T>

Borrow the underlying EventBus — useful when you want to share it with a non-WebSocket subscriber (e.g. an SSE handler).

Trait Implementations

impl<T: Clone + Clone + Send + 'static> Clone for WsHub<T>

fn clone(&self) -> WsHub<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.