Method complete_streaming_structured

core/src/llm/openai.rs:526–539

(
        &self,
        messages: &[Message],
        system: Option<&str>,
        tools: &[ToolDefinition],
        directive: &structured::StructuredDirective,
        cancel_token: tokio_util::sy

    }

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

impl OpenAiClient {