Skip to content

Commit 1b7b45d

Browse files
committed
1 parent 9781eb5 commit 1b7b45d

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

async-openai/src/client.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -394,9 +394,9 @@ impl<C: Config> Client<C> {
394394
while let Some(event_result) = event_stream.next().await {
395395
match event_result {
396396
Err(e) => {
397-
if let Err(_e) = tx.send(Err(OpenAIError::StreamError(
397+
if let Err(_e) = tx.send(Err(OpenAIError::StreamError(Box::new(
398398
StreamError::EventStream(e.to_string()),
399-
))) {
399+
)))) {
400400
break;
401401
}
402402
}
@@ -597,7 +597,7 @@ async fn map_stream_error(value: EventSourceError) -> OpenAIError {
597597
"Unreachable because read_response returns err when status_code {status_code} is invalid"
598598
))
599599
}
600-
_ => OpenAIError::StreamError(StreamError::ReqwestEventSource(value)),
600+
_ => OpenAIError::StreamError(Box::new(StreamError::ReqwestEventSource(value))),
601601
}
602602
}
603603

async-openai/src/error.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ pub enum OpenAIError {
2121
FileReadError(String),
2222
/// Error on SSE streaming
2323
#[error("stream failed: {0}")]
24-
StreamError(StreamError),
24+
StreamError(Box<StreamError>),
2525
/// Error from client side validation
2626
/// or when builder fails to build request before making API call
2727
#[error("invalid args: {0}")]

async-openai/src/types/assistant_stream.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,7 @@ impl TryFrom<eventsource_stream::Event> for AssistantStreamEvent {
207207
.map(AssistantStreamEvent::ErrorEvent),
208208
"done" => Ok(AssistantStreamEvent::Done(value.data)),
209209

210-
_ => Err(OpenAIError::StreamError(StreamError::UnknownEvent(value))),
210+
_ => Err(OpenAIError::StreamError(Box::new(StreamError::UnknownEvent(value)))),
211211
}
212212
}
213213
}

0 commit comments

Comments
 (0)