diff --git a/rust/crates/api/src/providers/openai_compat.rs b/rust/crates/api/src/providers/openai_compat.rs index b522a44..5480306 100644 --- a/rust/crates/api/src/providers/openai_compat.rs +++ b/rust/crates/api/src/providers/openai_compat.rs @@ -251,7 +251,7 @@ impl MessageStream { } if self.done { - self.pending.extend(self.state.finish()?); + self.pending.extend(self.state.finish()); if let Some(event) = self.pending.pop_front() { return Ok(Some(event)); } @@ -421,9 +421,9 @@ impl StreamState { events } - fn finish(&mut self) -> Result, ApiError> { + fn finish(&mut self) -> Vec { if self.message.finished { - return Ok(Vec::new()); + return Vec::new(); } self.message.finished = true; @@ -472,7 +472,7 @@ impl StreamState { })); events.push(StreamEvent::MessageStop(MessageStopEvent {})); } - Ok(events) + events } }