Struct Publisher 

pub struct Publisher<T>(Arc<Mutex<Vec<Sender<T>>>>);

A non-blocking fan-out publisher.

Each subscriber gets its own flume queue and cloning shares the subscriber registry. Self::subscribe gives a subscriber an unbounded, lossless queue; Self::subscribe_bounded gives a bounded queue that drops new events for that subscriber alone once it is full (use it for best-effort consumers that must not be able to grow memory without bound, e.g. ones fed by untrusted clients). Either way the producer never blocks and a slow subscriber never stalls the others.

Tuple Fields

0: Arc<Mutex<Vec<Sender<T>>>>

Implementations

impl<T: Clone> Publisher<T>

pub fn subscribe(&self) -> Receiver<T>

Registers a new subscriber with an unbounded, lossless queue and returns its receiver.

pub fn subscribe_bounded(&self, cap: usize) -> Receiver<T>

Registers a new subscriber with a bounded queue of capacity cap. When the subscriber falls cap events behind, the newest events are dropped for it alone (it keeps the oldest cap; the producer and other subscribers are unaffected).

pub fn publish(&self, msg: T)

Delivers msg to every subscriber. Never blocks: for a bounded subscriber that is full the event is dropped for that subscriber; a subscriber whose receiver is gone is pruned.

pub fn has_subscribers(&self) -> bool

Cheap check for whether any subscriber is registered. Does not prune, so it may briefly report true after the last receiver is gone (until the next Self::publish prunes it), but never reports false while a live subscriber exists.

Trait Implementations

impl<T> Clone for Publisher<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Default for Publisher<T>

fn default() -> Self

Returns the “default value” for a type.