From 838d82e19c878b1b38ba92acc99b17ad3ec0b390 Mon Sep 17 00:00:00 2001
From: Ahmed Ibrahim <aibrahim@openai.com>
Date: Wed, 22 Oct 2025 16:14:20 -0700
Subject: [PATCH] clean

---
 codex-rs/core/src/codex.rs | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/codex-rs/core/src/codex.rs b/codex-rs/core/src/codex.rs
index de4fe242f0..5319a21a82 100644
--- a/codex-rs/core/src/codex.rs
+++ b/codex-rs/core/src/codex.rs
@@ -1966,7 +1966,7 @@ async fn try_run_turn(
             Ok(event) => event,
             Err(codex_async_utils::CancelErr::Cancelled) => {
                 info!("Turn aborted");
-                let processed_items = finalize_turn(output).await?;
+                let processed_items = output.try_collect().await?;
                 return Err(CodexErr::TurnAborted {
                     dangling_artifacts: processed_items,
                 });
@@ -2086,7 +2086,7 @@ async fn try_run_turn(
                     let msg = EventMsg::TurnDiff(TurnDiffEvent { unified_diff });
                     sess.send_event(turn_context.as_ref(), msg).await;
                 }
-                let processed_items = finalize_turn(output).await?;
+                let processed_items = output.try_collect().await?;
                 return Ok(TurnRunResult {
                     processed_items,
                     total_token_usage: token_usage.clone(),
@@ -2123,14 +2123,6 @@ async fn try_run_turn(
     }
 }
 
-async fn finalize_turn<'a>(
-    output: FuturesOrdered<BoxFuture<'a, CodexResult<ProcessedResponseItem>>>,
-) -> CodexResult<Vec<ProcessedResponseItem>> {
-    let processed_items = output.try_collect().await?;
-
-    Ok(processed_items)
-}
-
 async fn handle_non_tool_response_item(
     sess: &Session,
     turn_context: Arc<TurnContext>,