update example now that StreamEnded is handled gracefully

Author: 64bit

examples/responses-function-call/src/main.rs

@@ -271,11 +271,6 @@ async fn run_streaming() -> Result<(), Box<dyn Error>> {
                         write!(stdout_lock, "{}: {}\n", delta.event_type(), delta.delta)?;
                         stdout().flush()?;
                     }
-                    ResponseStreamEvent::ResponseCompleted(completed) => {
-                        // todo remove once StreamEnded is fixed
-                        writeln!(stdout_lock, "{}\n", completed.event_type(),)?;
-                        break;
-                    }
                     _ => {
                         writeln!(stdout_lock, "{}: skipping\n", event.event_type())?;
                     }
@@ -346,11 +341,6 @@ async fn run_streaming() -> Result<(), Box<dyn Error>> {
                     write!(stdout_lock, "{}: {}\n", delta.event_type(), delta.delta)?;
                     stdout().flush()?;
                 }
-                ResponseStreamEvent::ResponseCompleted(completed) => {
-                    // todo remove once StreamEnded is fixed
-                    writeln!(stdout_lock, "{}\n", completed.event_type(),)?;
-                    break;
-                }
                 _ => {
                     writeln!(stdout_lock, "{}: skipping\n", event.event_type())?;
                 }

examples/responses-stream/src/main.rs

@@ -1,5 +1,6 @@
 use async_openai::{
     Client,
+    traits::EventType,
     types::responses::{CreateResponseArgs, ResponseStreamEvent},
 };
 use futures::StreamExt;
@@ -25,13 +26,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 ResponseStreamEvent::ResponseOutputTextDelta(delta) => {
                     write!(lock, "{}", delta.delta)?;
                 }
-                ResponseStreamEvent::ResponseCompleted(_)
-                | ResponseStreamEvent::ResponseIncomplete(_)
-                | ResponseStreamEvent::ResponseFailed(_) => {
-                    break;
-                }
                 _ => {
-                    writeln!(lock, "\n{response_event:#?}")?;
+                    writeln!(lock, "\n{}: skipping\n", response_event.event_type())?;
                 }
             },
             Err(e) => {

examples/responses-structured-outputs/src/main.rs

@@ -2,6 +2,7 @@ use std::error::Error;
 
 use async_openai::{
     config::OpenAIConfig,
+    traits::EventType,
     types::{
         chat::ResponseFormatJsonSchema,
         responses::{
@@ -370,12 +371,8 @@ async fn streaming_structured_output(client: &Client<OpenAIConfig>) -> Result<()
                     final_response = Some(completed.response);
                     break;
                 }
-                ResponseStreamEvent::ResponseFailed(_)
-                | ResponseStreamEvent::ResponseIncomplete(_) => {
-                    break;
-                }
                 _ => {
-                    // Ignore other events
+                    writeln!(lock, "\n{}: skipping\n", event.event_type())?;
                 }
             },
             Err(e) => {