Trait EventQueue 

pub trait EventQueue: Send + Sync {
    // Required methods
    fn poll(&self) -> Option<QueuedEvent>;
    fn push(&self, event: QueuedEvent);
    fn is_empty(&self) -> bool;
    fn len(&self) -> usize;

    // Provided method
    fn poll_batch(&self, max: usize) -> Vec<QueuedEvent> { ... }
}

Platform-agnostic event queue trait

Implementations provide different backing stores:

• MemoryEventQueue: Lock-free queue for general use
• TokioEventQueue: Integrates with Tokio channels (native only)

Required Methods

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

Poll for the next event (non-blocking)

Returns None if the queue is empty.

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

Provided Methods

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

Try to receive multiple events at once (batch poll)

Returns up to max events. Default implementation polls repeatedly.

Implementors

impl EventQueue for MemoryEventQueue