Struct Broker 

pub struct Broker<M: Message, T: TopicId> { /* private fields */ }

Broker that manages topics

Implementations

impl<M: Message, T: TopicId> Broker<M, T>

pub fn new(opts: Opts, metrics: Metrics) -> Self

Create a new Broker

pub fn topic_get(&self, topic: &T) -> Option<Arc<Topic<M>>>

Fetches the given topic if it exists

pub fn topic_get_or_create(&self, topic: &T) -> Arc<Topic<M>>

Fetches or creates the given topic

pub fn topic_exists(&self, topic: &T) -> bool

Tells if the given topic exists

pub fn topic_remove(&self, topic: &T)

Removes the given topic. If there are subscribers - they will get a RecvError.

pub fn subscribe(&self, topic: &T) -> Result<Subscriber<M>, SubscribeError>

Shorthand for topic_get_or_create().subscribe(topic)

pub fn publish(&self, topic: &T, message: M) -> Result<usize, PublishError>

Shorthand for topic_get().publish(message)

Trait Implementations

impl<M: Clone + Message, T: Clone + TopicId> Clone for Broker<M, T>

fn clone(&self) -> Broker<M, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: Debug + Message, T: Debug + TopicId> Debug for Broker<M, T>

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

Formats the value using the given formatter.