fix(api): return final stream events directly from finish
Resolves clippy::unnecessary_wraps on StreamState::finish in openai_compat.rs. Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent) Co-authored-by: Sisyphus <clio-agent@sisyphuslabs.ai>
This commit is contained in:
parent
d9c1883879
commit
7976bf994c
1 changed files with 4 additions and 4 deletions
|
|
@ -251,7 +251,7 @@ impl MessageStream {
|
||||||
}
|
}
|
||||||
|
|
||||||
if self.done {
|
if self.done {
|
||||||
self.pending.extend(self.state.finish()?);
|
self.pending.extend(self.state.finish());
|
||||||
if let Some(event) = self.pending.pop_front() {
|
if let Some(event) = self.pending.pop_front() {
|
||||||
return Ok(Some(event));
|
return Ok(Some(event));
|
||||||
}
|
}
|
||||||
|
|
@ -421,9 +421,9 @@ impl StreamState {
|
||||||
events
|
events
|
||||||
}
|
}
|
||||||
|
|
||||||
fn finish(&mut self) -> Result<Vec<StreamEvent>, ApiError> {
|
fn finish(&mut self) -> Vec<StreamEvent> {
|
||||||
if self.message.finished {
|
if self.message.finished {
|
||||||
return Ok(Vec::new());
|
return Vec::new();
|
||||||
}
|
}
|
||||||
self.message.finished = true;
|
self.message.finished = true;
|
||||||
|
|
||||||
|
|
@ -472,7 +472,7 @@ impl StreamState {
|
||||||
}));
|
}));
|
||||||
events.push(StreamEvent::MessageStop(MessageStopEvent {}));
|
events.push(StreamEvent::MessageStop(MessageStopEvent {}));
|
||||||
}
|
}
|
||||||
Ok(events)
|
events
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue