Trait NotificationProcessor 

pub trait NotificationProcessor<M>: Send + Sync
where
    M: RexMessage,
{
    // Required methods
    fn init(
        &mut self,
        join_set: &mut JoinSet<()>,
    ) -> UnboundedSender<Notification<M>>;
    fn get_topics(&self) -> &[M::Topic];
}

Required Methods

fn init( &mut self, join_set: &mut JoinSet<()>, ) -> UnboundedSender<Notification<M>>

fn get_topics(&self) -> &[M::Topic]

Implementors

impl<K> NotificationProcessor<<K as Rex>::Message> for IngressAdapter<K>

where K: Rex + Ingress, K::Input: TryFrom<K::In, Error = Report<ConversionError>>, K::Message: TryInto<K::Out, Error = Report<ConversionError>>,

impl<K> NotificationProcessor<<K as Rex>::Message> for TimeoutManager<K>

where K: Rex + Timeout, K::Message: TimeoutMessage<K>,