Function collect_events

core/src/tool_confirmation.rs:160–166

(rx: &mut mpsc::Receiver<AgentEvent>, count: usize)

    }

    async fn collect_events(rx: &mut mpsc::Receiver<AgentEvent>, count: usize) -> Vec<AgentEvent> {
        let mut events = Vec::new();
        for _ in 0..count {
            events.push(rx.recv().await.expect("missing forwarded event"));
        }
        events
    }

    #[tokio::test]
    async fn approved_confirmation_returns_approved_and_forwards_events() {