Trait ztopic::Topic

pub trait Topic<S, K>
where
    K: Clone + Default + Hash + Eq,
    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;

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

    // Provided method
    fn topic_id(&self) -> impl Debug + Hash { ... }
}

Required Associated Types

type Output

type Error

type References

type Storage

Required Methods

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

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

Provided Methods

fn topic_id(&self) -> impl Debug + Hash

Object Safety

This trait is not object safe.

Implementors

impl<I, O, E, S> Topic<S, ()> for Empty<I, O, E>

where I: Debug + Hash + Clone + Send + 'static, O: Send + 'static, E: Send + 'static, S: Send + 'static,

type Output = O

type Error = E

type References = RawRef<<Empty<I, O, E> as Topic<S, ()>>::Output>

type Storage = Broadcast<<Empty<I, O, E> as Topic<S, ()>>::Output>

impl<S> Topic<S, ()> for Interval

type Output = Instant

type Error = Infallible

type References = RawRef<<Interval as Topic<S, ()>>::Output>

type Storage = Broadcast<<Interval as Topic<S, ()>>::Output>