Struct foco::Broker

pub struct Broker<M> where
    M: TopicMeta + Default + Copy,  { /* fields omitted */ }

One message Broker per topic-constrained type: Each Broker provides a map from topic to message queue

Implementations

impl<M> Broker<M> where
    M: TopicMeta + Default + Copy,
    <M as TopicMeta>::MsgType: Default + Copy + Debug, 

pub fn new() -> Self

pub fn subscribe(&mut self, instance: PublisherId) -> Option<Subscription<M>>

Subscribe to a topic (and specific instance if desired) Use ANY_PUBLISHER to subscribe to the first available publisher

pub fn advertise(&mut self) -> Option<Advertisement<M>>

Advertise on a topic. This provides a publisher a route to publication

pub fn publish(&mut self, advert: &Advertisement<M>, msg: &M::MsgType)

Publish a new message on the topic

pub fn pub_registered(&self, instance: PublisherId) -> bool

Has this publisher already advertised? This merely tells the caller whether we have n >= instance number of registered (advertised) publishers.

pub fn group_count(&self) -> u32

How many publishers have advertised on this topic?

pub fn poll(&self, sub: &mut Subscription<M>) -> Result<M::MsgType, ()>

Read the next message from the topic Returns nb::Error::WouldBlock if the read would block