Struct simple_pub_sub::topics::TopicMap

pub struct TopicMap {
    pub map: BTreeMap<String, HashMap<String, Sender<Msg>>>,
}

The TopicMap struct is used to store the channels for a given topic.

Fields

map: BTreeMap<String, HashMap<String, Sender<Msg>>>

Implementations

impl TopicMap

pub fn query(&self, topic: String) -> String

Returns the number of connected clients for a given topic.

pub fn add_channel( &mut self, topic: String, client_id: String, channel: Sender<Msg>, )

Adds a channel to the map.

pub fn remove_channel(&mut self, topic: String, client_id: String)

Removes a channel from the map.

pub fn add_topic(&mut self, topic: String)

adds a topic to the map.

pub async fn publish(&mut self, msg: Msg)

Publishes the message to the channels.

Trait Implementations

impl Clone for TopicMap

fn clone(&self) -> TopicMap

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TopicMap

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

Formats the value using the given formatter.