Struct Bus 

pub struct Bus<M> { /* private fields */ }

Lock-free bounded MPMC message bus with explicit backpressure.

Implementations

impl<M: Send + 'static> Bus<M>

pub fn new(capacity: usize) -> Self

pub fn sender(&self) -> BusSender<M>

pub fn receiver(&self) -> &Receiver<M>

pub fn capacity(&self) -> usize

pub fn dropped_count(&self) -> u64

Trait Implementations

impl<M: Debug> Debug for Bus<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.