Struct EventQueue 

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

Thread-safe in-memory FIFO event queue.

Implementations

impl<T> EventQueue<T>

pub fn new() -> Self

Creates an empty event queue.

pub fn push(&self, e: T) -> Result<(), EventQueueError>

Pushes an event to the back of the queue and wakes one waiter.

pub fn push_front(&self, e: T) -> Result<(), EventQueueError>

Pushes an event to the front of the queue and wakes one waiter.

pub fn poll(&self) -> Result<Option<T>, EventQueueError>

Waits briefly for an event, then returns the next event if one is available.

pub fn pop(&self) -> Result<Option<T>, EventQueueError>

Returns the next event immediately, or None if the queue is empty.

pub fn len(&self) -> Result<usize, EventQueueError>

Returns the number of events currently in the queue.

pub fn is_empty(&self) -> Result<bool, EventQueueError>

Returns whether the queue currently contains no events.

Trait Implementations

impl<T: Debug> Debug for EventQueue<T>

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

Formats the value using the given formatter.

impl<T: Default> Default for EventQueue<T>

fn default() -> EventQueue<T>

Returns the “default value” for a type.