Struct RecoveryQueue

pub struct RecoveryQueue<Item> { /* private fields */ }

A recovery queue is used to store packets that need to be resent. This is used for sequenced and ordered packets.

Implementations

impl<Item> RecoveryQueue<Item>

where Item: Clone,

pub fn new() -> Self

pub fn insert_id(&mut self, seq: u32, item: Item)

pub fn get_all(&mut self) -> Vec<(u32, Item)>

pub fn flush_old(&mut self, threshold: u64) -> Vec<Item>

Trait Implementations

impl<Item: Clone> Clone for RecoveryQueue<Item>

fn clone(&self) -> RecoveryQueue<Item>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Item: Debug> Debug for RecoveryQueue<Item>

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

Formats the value using the given formatter.

impl<Item> NetQueue<Item> for RecoveryQueue<Item>

type KeyId = u32

The Item of the queue. The “key” that each Item is stored under (used for removal)

type Error = ()

A custom error specifier for NetQueueError

fn insert( &mut self, item: Item, ) -> Result<Self::KeyId, NetQueueError<Self::Error>>

Inserts Item into the queue, given the conditions are fulfilled.

fn remove( &mut self, key: Self::KeyId, ) -> Result<Item, NetQueueError<Self::Error>>

Remove an Item from the queue by providing an instance of Self::KeyId

fn get(&mut self, key: Self::KeyId) -> Result<&Item, NetQueueError<Self::Error>>

Retrieves an Item from the queue, by reference.

fn flush(&mut self) -> Result<Vec<Item>, NetQueueError<Self::Error>>

Clears the entire queue.