From 70c12c19f51b97991eaff0daa7b96f4145a5b0fb Mon Sep 17 00:00:00 2001
From: Ahmed Ibrahim <aibrahim@openai.com>
Date: Tue, 5 Aug 2025 01:29:46 -0700
Subject: [PATCH] fmt

---
 codex-rs/core/src/chat_completions.rs | 18 +++++-------------
 1 file changed, 5 insertions(+), 13 deletions(-)

diff --git a/codex-rs/core/src/chat_completions.rs b/codex-rs/core/src/chat_completions.rs
index e8be21f4f7..681caa7def 100644
--- a/codex-rs/core/src/chat_completions.rs
+++ b/codex-rs/core/src/chat_completions.rs
@@ -248,9 +248,7 @@ async fn process_chat_sse<S>(
                     }],
                     id: None,
                 };
-                let _ = tx_event
-                    .send(Ok(ResponseEvent::OutputItemDone(item)))
-                    .await;
+                let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
             }
 
             if !reasoning_text.is_empty() {
@@ -262,9 +260,7 @@ async fn process_chat_sse<S>(
                     }]),
                     encrypted_content: None,
                 };
-                let _ = tx_event
-                    .send(Ok(ResponseEvent::OutputItemDone(item)))
-                    .await;
+                let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
             }
 
             let _ = tx_event
@@ -374,9 +370,7 @@ async fn process_chat_sse<S>(
                                 }]),
                                 encrypted_content: None,
                             };
-                            let _ = tx_event
-                                .send(Ok(ResponseEvent::OutputItemDone(item)))
-                                .await;
+                            let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
                         }
 
                         // Then emit the FunctionCall response item.
@@ -412,9 +406,7 @@ async fn process_chat_sse<S>(
                                 }]),
                                 encrypted_content: None,
                             };
-                            let _ = tx_event
-                                .send(Ok(ResponseEvent::OutputItemDone(item)))
-                                .await;
+                            let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
                         }
                     }
                     _ => {}
@@ -645,4 +637,4 @@ impl<S> AggregatedChatStream<S> {
     pub(crate) fn streaming_mode(inner: S) -> Self {
         Self::new(inner, AggregateMode::Streaming)
     }
-}
\ No newline at end of file
+}