Method complete_streaming

core/src/llm/openai.rs:512–524

(
        &self,
        messages: &[Message],
        system: Option<&str>,
        tools: &[ToolDefinition],
        cancel_token: tokio_util::sync::CancellationToken,
    )

    }

    async fn complete_streaming(
        &self,
        messages: &[Message],
        system: Option<&str>,
        tools: &[ToolDefinition],
        cancel_token: tokio_util::sync::CancellationToken,
    ) -> Result<mpsc::Receiver<StreamEvent>> {
        self.send_streaming(
            self.build_chat_request(messages, system, tools, None),
            cancel_token,
        )
        .await
    }

    async fn complete_streaming_structured(
        &self,