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

use std::{fmt::Debug, hash::Hash, ops::Deref};

use futures::stream::BoxStream;

use crate::{manager::TopicManager, storages::StorageManager, Storage};

#[allow(unused_variables)]
pub trait Topic<S, K>
where
    K: Clone + Default + Eq + Hash + Ord,
    Self: Send + 'static,
    Self::Output: Send + 'static,
    Self::Error: Send + 'static,
    Self::References: Deref<Target = Self::Output> + for<'a> From<&'a Self::Output> + 'static,
    Self::Storage: Storage<Self::Output> + 'static,
{
    type Output;

    type Error;

    type References;

    type Storage;

    fn topic_id(&self) -> impl Debug {}

    fn storage(&self) -> Self::Storage;

    fn mount(&self, manager: TopicManager<S>, storage: StorageManager<K, Self::Output, Self::Storage>) -> BoxStream<'static, Result<(), Self::Error>>;
}