Struct PendingHandoffQueue 

pub struct PendingHandoffQueue<T> { /* private fields */ }

FIFO queue for pending handoffs that cannot grow past its configured bound.

Implementations

impl<T> PendingHandoffQueue<T>

pub fn new() -> Self

Create an empty queue with default bounds.

pub fn with_config(config: PendingHandoffQueueConfig) -> Self

Create an empty queue with explicit bounds.

pub fn config(&self) -> PendingHandoffQueueConfig

Return the active queue bounds.

pub fn pending_len(&self) -> usize

Return the number of currently pending, non-pruned handoffs.

pub fn is_empty(&self) -> bool

Return true when no handoffs are pending.

pub fn enqueue( &mut self, handoff: T, now: Instant, ) -> Result<(), PendingHandoffOverflow>

Enqueue one handoff in FIFO order.

Expired entries are pruned first. If the backlog is still full, the caller must use the returned overflow decision to fall back to reconnect.

pub fn dequeue(&mut self, now: Instant) -> Option<T>

Dequeue the oldest non-expired handoff.

pub fn expire(&mut self, now: Instant) -> usize

Drop all expired pending handoffs and return the number removed.

Trait Implementations

impl<T: Debug> Debug for PendingHandoffQueue<T>

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

Formats the value using the given formatter.

impl<T> Default for PendingHandoffQueue<T>

fn default() -> Self

Returns the “default value” for a type.