ztopic 0.3.18

A topic-based pub/sub library for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use std::{any::Any, collections::BTreeMap, fmt::Debug, hash::Hash, sync::Arc};

use parking_lot::Mutex;

use crate::{token::TopicToken, topic::Topic, Storage};

type AnyTopic = Box<dyn Any + Send + Sync>;

#[derive(Debug)]
pub struct TopicManager<S> {
    store: Arc<S>,
    topics: Arc<Mutex<BTreeMap<String, Option<AnyTopic>>>>,
}

impl<S> Clone for TopicManager<S> {
    fn clone(&self) -> Self {
        Self {
            store: self.store.clone(),
            topics: self.topics.clone(),
        }
    }
}

impl<S> TopicManager<S> {
    pub fn new(store: S) -> Self {
        Self {
            store: Arc::new(store),
            topics: Arc::new(Mutex::new(BTreeMap::new())),
        }
    }

    pub fn store(&self) -> &S {
        &self.store
    }

    pub fn topic<T, K>(&self, topic: T) -> TopicToken<T, S, K>
    where
        T: Topic<S, K>,
        T::Storage: Storage<T::Output> + Send + Sync + 'static,
        S: Send + Sync + 'static,
        K: Default + Clone + Eq + Hash + Ord + Send + Sync + Unpin + 'static,
    {
        TopicToken::<T, S, K>::new(topic, self.clone())
    }

    pub(crate) fn topics(&self) -> &Mutex<BTreeMap<String, Option<AnyTopic>>> {
        &self.topics
    }
}