Trait rex::notification::NotificationProcessor

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

Required Methods

fn init(&self) -> UnboundedSender<Notification<M>>

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

Implementors

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

where K: Rex, K::Message: TryInto<TimeoutInput<K>>, <K::Message as TryInto<TimeoutInput<K>>>::Error: Send,

impl<K, In, Out> NotificationProcessor<<K as Rex>::Message> for IngressAdapter<K, In, Out>

where for<'a> K: Rex + TryFrom<&'a In, Error = Report<ConversionError>>, K::Input: TryFrom<In, Error = Report<ConversionError>>, K::Message: TryInto<Out, Error = Report<ConversionError>>, In: Send + Sync + Debug + 'static, Out: Send + Sync + Debug + 'static,