Struct BroadcastHub 

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

Fan one source to many dynamic consumers.

Implementations

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

pub fn new(buffer_size: usize) -> Self

pub fn attach(&self, source: Source<T>)

Attach a producer source. Spawns a task that pumps each element into the broadcast channel; returns immediately.

pub fn consumer(&self) -> Source<T>

Return a new consumer source. Yields elements broadcast after this call (late subscribers miss earlier elements). Slow subscribers silently skip lagged elements.

pub fn consumer_count(&self) -> usize

Number of currently-attached consumers.