From 4d4a100fe6fcde7ca3afcf7971ac387d355349eb Mon Sep 17 00:00:00 2001 From: sigoden Date: Mon, 29 Apr 2024 23:04:25 +0800 Subject: refactor: sse handling (#465) --- src/client/ernie.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/client/ernie.rs') diff --git a/src/client/ernie.rs b/src/client/ernie.rs index 4038e0d..5e600af 100644 --- a/src/client/ernie.rs +++ b/src/client/ernie.rs @@ -1,6 +1,6 @@ use super::{ maybe_catch_error, patch_system_message, sse_stream, Client, CompletionDetails, ErnieClient, - ExtraConfig, Model, ModelConfig, PromptType, SendData, SseHandler, + ExtraConfig, Model, ModelConfig, PromptType, SendData, SsMmessage, SseHandler, }; use crate::utils::PromptKind; @@ -106,8 +106,8 @@ async fn send_message(builder: RequestBuilder) -> Result<(String, CompletionDeta } async fn send_message_streaming(builder: RequestBuilder, handler: &mut SseHandler) -> Result<()> { - let handle = |data: &str| -> Result { - let data: Value = serde_json::from_str(data)?; + let handle = |message: SsMmessage| -> Result { + let data: Value = serde_json::from_str(&message.data)?; if let Some(text) = data["result"].as_str() { handler.text(text)?; } -- cgit v1.2.3