Struct EventQueue 

pub struct EventQueue { /* private fields */ }

Implementations

impl EventQueue

pub fn new(capacity: usize) -> Self

pub fn push(&self, event: Event) -> Result<(), String>

Push an event. Critical goes to front, High goes after existing Criticals, everything else goes to the back. Returns Err if queue is full.

pub fn push_priority(&self, event: Event)

Force push to front regardless of severity. Evicts the oldest (back) if full.

pub fn pop(&self) -> Option<Event>

pub fn peek(&self) -> Option<Event>

pub fn len(&self) -> usize

pub fn notified(&self) -> impl Future<Output = ()> + '_

Wait until an event is pushed. Use in tokio::select! for instant wake.

pub fn is_empty(&self) -> bool

pub fn drain(&self) -> Vec<Event>