diff --git a/crates/meilisearch/src/routes/chats/utils.rs b/crates/meilisearch/src/routes/chats/utils.rs index ee3a1bf27..752eb10e6 100644 --- a/crates/meilisearch/src/routes/chats/utils.rs +++ b/crates/meilisearch/src/routes/chats/utils.rs @@ -197,7 +197,10 @@ impl SseEventSender { } pub async fn stop(self) -> Result<(), SendError> { - self.0.send(Event::Data(sse::Data::new("[DONE]"))).await + // It is the way OpenAI sends a correct end of stream + // + const DONE_DATA: &str = "[DONE]"; + self.0.send(Event::Data(sse::Data::new(DONE_DATA))).await } async fn send_json(&self, data: &S) -> Result<(), SendError> {