Method wait_for_events

src/crates/execution/agent-runtime/src/event_queue.rs:214–216

Wait for events (used for consumers)

(&self)

    /// Wait for events (used for consumers)
    pub async fn wait_for_events(&self) {
        self.notify.notified().await;
    }

    /// Get queue size
    pub async fn len(&self) -> usize {