Struct EventQueue 

pub struct EventQueue { /* private fields */ }

Async mpsc-based ordered event queue.

Inputs are processed strictly in the order they arrive.

Implementations

impl EventQueue

pub fn new() -> (Self, EventQueueHandle)

Create a new event queue, returning both the queue (consumer) and a cloneable handle (producer).

pub async fn process<F, Fut>(self, handler: F)

where F: Fn(KeelInput) -> Fut, Fut: Future<Output = ()>,

Process inputs in order, calling handler for each one.

Runs until the queue is closed (all handles dropped) or the provided shutdown future resolves.

pub async fn process_until<F, Fut>(self, handler: F, shutdown: Receiver<bool>)

where F: Fn(KeelInput) -> Fut, Fut: Future<Output = ()>,

Process inputs with a shutdown signal.

Stops when either all producer handles are dropped or shutdown resolves — whichever comes first.