Struct MemoryEventQueue 

pub struct MemoryEventQueue { /* private fields */ }

In-memory event queue using crossbeam’s lock-free queue

This implementation works everywhere (native, no_std with alloc).

Implementations

impl MemoryEventQueue

pub fn new() -> Self

Create a new empty queue

Trait Implementations

impl Default for MemoryEventQueue

fn default() -> Self

Returns the “default value” for a type.

impl EventQueue for MemoryEventQueue

fn poll(&self) -> Option<QueuedEvent>

Poll for the next event (non-blocking)

fn push(&self, event: QueuedEvent)

Push an event onto the queue

fn is_empty(&self) -> bool

Check if the queue is empty

fn len(&self) -> usize

Get the number of pending events

fn poll_batch(&self, max: usize) -> Vec<QueuedEvent>

Try to receive multiple events at once (batch poll)