Struct Hub 

pub struct Hub<T> { /* private fields */ }

Named rooms with fan-out; cheap to clone, all clones share the rooms

Implementations

impl<T: Clone + Send + 'static> Hub<T>

pub fn new(capacity: usize) -> Self

capacity: messages buffered per room for slow subscribers (at least 1)

pub fn subscribe(&self, room: &str) -> Subscription<T>

Join room, creating it if needed. Only messages published after this call arrive.

pub fn publish(&self, room: &str, message: T) -> usize

Send to everyone currently in room; returns how many received it (0 for a room nobody is in)

pub fn members(&self, room: &str) -> usize

Subscribers in room

pub fn rooms(&self) -> Vec<(String, usize)>

Rooms with at least one member, with their member counts, by name

Trait Implementations

impl<T> Clone for Hub<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.