Struct DefaultQueue 

pub struct DefaultQueue<TKey, TMsg>
where
    TKey: JobKey,
    TMsg: Message,
{ /* private fields */ }

A simple, no-priority queue

Equivalent to a VecDeque

Trait Implementations

impl<TKey, TMsg> Debug for DefaultQueue<TKey, TMsg>

where TKey: JobKey, TMsg: Message,

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

Formats the value using the given formatter.

impl<TKey, TMsg> Default for DefaultQueue<TKey, TMsg>

where TKey: JobKey, TMsg: Message,

fn default() -> DefaultQueue<TKey, TMsg>

Returns the “default value” for a type.

impl<TKey, TMsg> Queue<TKey, TMsg> for DefaultQueue<TKey, TMsg>

where TKey: JobKey, TMsg: Message,

fn len(&self) -> usize

Retrieve the size of the factory’s queue

fn is_empty(&self) -> bool

Check if the queue is empty

fn pop_front(&mut self) -> Option<Job<TKey, TMsg>>

Pop the next message from the front of the queue

fn push_back(&mut self, job: Job<TKey, TMsg>)

Push an item to the back of the queue, with the given priority

fn remove_expired_items( &mut self, discard_handler: &Option<Arc<dyn DiscardHandler<TKey, TMsg>>>, ) -> usize

Remove expired items from the queue

fn discard_oldest(&mut self) -> Option<Job<TKey, TMsg>>

Try and discard a message according to the queue semantics in an overload scenario (e.g. lowest priority if priority queueing). In a basic queueing scenario, this is equivalent to pop_front

fn peek(&self) -> Option<&Job<TKey, TMsg>>

Peek an item from the head of the queue

fn is_job_discardable(&self, _key: &TKey) -> bool

Determine if a given job can be discarded. Default is true for all jobs.