diff --git a/src/openai_compat.rs b/src/openai_compat.rs index 91f7955..4bdce46 100644 --- a/src/openai_compat.rs +++ b/src/openai_compat.rs @@ -218,10 +218,7 @@ pub async fn chat_completions( finish_reason: None, }], }; - let _ = tx_tokens.send(format!( - "data: {}\n\n", - serde_json::to_string(&initial_chunk).unwrap() - )); + let _ = tx_tokens.send(serde_json::to_string(&initial_chunk).unwrap()); // Generate and stream tokens let _ = loaded @@ -243,10 +240,7 @@ pub async fn chat_completions( finish_reason: None, }], }; - let _ = tx_tokens.send(format!( - "data: {}\n\n", - serde_json::to_string(&chunk).unwrap() - )); + let _ = tx_tokens.send(serde_json::to_string(&chunk).unwrap()); })), ) .await; @@ -266,11 +260,8 @@ pub async fn chat_completions( finish_reason: Some("stop".to_string()), }], }; - let _ = tx.send(format!( - "data: {}\n\n", - serde_json::to_string(&final_chunk).unwrap() - )); - let _ = tx.send("data: [DONE]\n\n".to_string()); + let _ = tx.send(serde_json::to_string(&final_chunk).unwrap()); + let _ = tx.send("[DONE]".to_string()); }); let stream = UnboundedReceiverStream::new(rx)