Struct RawEventQueue 

pub struct RawEventQueue { /* private fields */ }

An event queue that buffers incoming SimpleX events independently of client activity.

Backed by an unbounded channel. If events are not consumed they accumulate indefinitely. Drop the queue as soon as it is no longer needed. When dropped while a chat instance is active and producing events, the Haskell-side queue is still drained continuously - events are discarded in Rust and do not accumulate in the FFI layer.

Implementations

impl RawEventQueue

pub async fn next_event(&mut self) -> Option<Result<Event>>

Returns the next event from the queue, or None if the chat has shut down.

pub fn into_receiver(self) -> EventReceiver

Unwraps the queue into the underlying tokio unbounded receiver for more advanced use cases.