Method record_agent_event

core/src/agent_api/tests.rs:177–183

(&self, event: &AgentEvent, run_id: &str, session_id: &str)

    }

    async fn record_agent_event(&self, event: &AgentEvent, run_id: &str, session_id: &str) {
        self.events.lock().unwrap().push((
            run_id.to_string(),
            session_id.to_string(),
            event.clone(),
        ));
    }
}

impl CancellableStreamingClient {