Function drain_to_done

core/src/llm/openai.rs:1280–1298

(client: &OpenAiClient)

    }

    async fn drain_to_done(client: &OpenAiClient) -> crate::llm::LlmResponse {
        use crate::llm::{LlmClient, StreamEvent};
        let mut rx = client
            .complete_streaming(
                &[Message::user("go")],
                None,
                &[],
                tokio_util::sync::CancellationToken::new(),
            )
            .await
            .expect("stream opened");
        let mut done = None;
        while let Some(ev) = rx.recv().await {
            if let StreamEvent::Done(resp) = ev {
                done = Some(resp);
            }
        }
        done.expect("a Done event")
    }

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