diff --git a/src/providers/openai.rs b/src/providers/openai.rs
index f554f424..d1cc139f 100644
--- a/src/providers/openai.rs
+++ b/src/providers/openai.rs
@@ -524,6 +524,7 @@ impl super::Provider for OpenAIProvider {
                         }
                     }
                     Ok(_) => continue,
+                    Err(reqwest_eventsource::Error::StreamEnded) => break,
                     Err(e) => {
                         // Attempt to probe for the actual error body
                         let probe_resp = probe_client
@@ -887,6 +888,7 @@ impl super::Provider for OpenAIProvider {
                         }
                     }
                     Ok(_) => continue,
+                    Err(reqwest_eventsource::Error::StreamEnded) => break,
                     Err(e) => {
                          // Attempt to probe for the actual error body
                         let probe_resp = probe_client