Struct QueuePublisher

pub struct QueuePublisher<T: Sized + Copy> { /* private fields */ }

A pub-sub queue. An item sent to the publisher is sent to every subscriber.

Implementations

impl<T: Sized + Copy> QueuePublisher<T>

pub fn new() -> Result<QueuePublisher<T>, FreeRtosError>

Create a new publisher

pub fn send<D: DurationTicks>(&self, item: T, max_wait: D) -> usize

Send an item to every subscriber. Returns the number of subscribers that have received the item.

pub fn subscribe<D: DurationTicks>( &self, max_size: usize, create_max_wait: D, ) -> Result<QueueSubscriber<T>, FreeRtosError>

Subscribe to this publisher. Can accept a fixed amount of items.

Trait Implementations

impl<T: Sized + Copy> Clone for QueuePublisher<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.