does this lib support Microsoft Azure OpenAI Service stream response

[jiangxiaoqiang]

I have write a non SSE stream api:

async fn chat_completion(
    client: &Client<AzureConfig>,
    tx: UnboundedSender<SSEMessage<String>>,
    req: &AskReq,
    login_user_info: &LoginUserInfo,
) -> Result<String, Box<dyn Error>> {
    let request = CreateChatCompletionRequestArgs::default()
        .max_tokens(512u16)
        .model("gpt-3.5-turbo")
        .messages([
            ChatCompletionRequestSystemMessageArgs::default()
                .content("You are a helpful assistant.")
                .build()?
                .into(),
            ChatCompletionRequestUserMessageArgs::default()
                .content(req.prompt.as_str())
                .build()?
                .into(),
        ])
        .build()?;

    let response: CreateChatCompletionResponse = client.chat().create(request).await?;
    let msg_string = serde_json::to_string(&response);
    if let Err(e) = msg_string {
        error!("serial json failed,{}", e);
        return Ok("".to_owned());
    }
    let send_msg = msg_string.unwrap();
    do_msg_send_sync(&send_msg, &tx, "chat");
    let choice = response.choices[0].clone();
    let msg = choice.message.content.unwrap_or_default();
    if req.cid.is_none() || req.cid.unwrap() == 0 {
        let conv = create_conversation(&req.prompt, &login_user_info.userId);
        create_conversation_item(&req.prompt, &msg, conv.id);
    }
    create_conversation_item(&req.prompt, &msg, req.cid.unwrap());
    Ok("".to_owned())
}

how to make these support the Microsoft Azure OpenAI Service SSE stream? is it possible? I did not found any example.

[64bit]

Its a known issue, PR with fix is welcome.

https://github.com/64bit/async-openai/blob/main/examples/azure-openai-service/src/main.rs#L40