Struct rex::timeout::TimeoutManager
source · pub struct TimeoutManager<K>where
K: Rex,{ /* private fields */ }Expand description
Processes incoming Operations and modifies the [TimeoutLedger]
through a polling loop.
Implementations§
source§impl<K> TimeoutManager<K>where
K: Rex,
K::Message: TryInto<TimeoutInput<K>>,
<K::Message as TryInto<TimeoutInput<K>>>::Error: Send,
impl<K> TimeoutManager<K>where
K: Rex,
K::Message: TryInto<TimeoutInput<K>>,
<K::Message as TryInto<TimeoutInput<K>>>::Error: Send,
pub fn new( signal_queue: Arc<SignalQueue<K>>, topic: impl Into<<K::Message as RexMessage>::Topic> ) -> Self
pub fn with_tick_rate(self, tick_rate: Duration) -> Self
pub fn init_inner(&self) -> UnboundedSender<Notification<K::Message>>
Trait Implementations§
source§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> NotificationProcessor<<K as Rex>::Message> for TimeoutManager<K>where
K: Rex,
K::Message: TryInto<TimeoutInput<K>>,
<K::Message as TryInto<TimeoutInput<K>>>::Error: Send,
fn init(&self) -> UnboundedSender<Notification<K::Message>>
fn get_topics(&self) -> &[<K::Message as RexMessage>::Topic]
Auto Trait Implementations§
impl<K> !RefUnwindSafe for TimeoutManager<K>
impl<K> Send for TimeoutManager<K>
impl<K> Sync for TimeoutManager<K>
impl<K> Unpin for TimeoutManager<K>
impl<K> !UnwindSafe for TimeoutManager<K>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more