Trait ztopic::Topic

pub trait Topic<S, K>
where
    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<K, Self::Output> + 'static,
{
    type Output;
    type Error;
    type References;
    type Storage;

    // Required methods
    fn storage(&self) -> Self::Storage;
    fn mount(
        &mut self,
        manager: TopicManager<S>,
        storage: Self::Storage,
    ) -> impl Stream<Item = Result<(), Self::Error>> + Send + 'static;

    // 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( &mut self, manager: TopicManager<S>, storage: Self::Storage, ) -> impl Stream<Item = Result<(), Self::Error>> + Send + 'static

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>