pub fn agent_loop(
prompts: Vec<Message>,
config: AgentLoopConfig,
cancel: CancellationToken,
) -> EventStreamConsumer<AgentEvent, Vec<Message>>pub fn agent_loop(
prompts: Vec<Message>,
config: AgentLoopConfig,
cancel: CancellationToken,
) -> EventStreamConsumer<AgentEvent, Vec<Message>>