Struct bus_queue::sync::Publisher

pub struct Publisher<T: Send> { /* fields omitted */ }

Provides an interface for the publisher

Methods

impl<T: Send> Publisher<T>

pub fn broadcast(&mut self, object: T) -> Result<(), SendError<T>>

Publishes values to the circular buffer at wi % size

Arguments

• object - owned object to be published

pub fn wake_all(&self)

Trait Implementations

impl<T: Send> GetSubCount for Publisher<T>

fn get_sub_count(&self) -> usize

impl<T: Send> PartialEq<Publisher<T>> for Publisher<T>

fn eq(&self, other: &Publisher<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

#[must_use] fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl<T: Send> Drop for Publisher<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send> Eq for Publisher<T>

impl<T: Debug + Send> Debug for Publisher<T>

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

Formats the value using the given formatter.