Struct rumqttlog::waiters::Waiters

pub struct Waiters<T> { /* fields omitted */ }

TopicsWaiters are connections which are waiting to be notified of new topics. Notifications can sometimes be false positives for topics a connection (e.g replicator connection and new topic due to replicator data). This connection should be polled again for next notification. Having 2 waiters to prevents infinite waiter loops while trying to add connection back to waiter queue

Implementations

impl<T> Waiters<T>

pub fn new() -> Waiters<T>

pub fn register(&mut self, id: usize, request: T)

Pushes a request to current wait queue

pub fn pop_front(&mut self) -> Option<(usize, T)>

Pops a request from current wait queue

pub fn push_back(&mut self, id: usize, request: T)

Pushes a request to next wait queue

pub fn prepare_next(&mut self)

Swaps next wait queue with current wait queue

pub fn remove(&mut self, id: usize) -> Option<T>

Remove a connection from waiters

Trait Implementations

impl<T: Debug> Debug for Waiters<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.