diff --git a/codex-rs/core/config.schema.json b/codex-rs/core/config.schema.json
index 876180dd7e..0a48882b09 100644
--- a/codex-rs/core/config.schema.json
+++ b/codex-rs/core/config.schema.json
@@ -469,6 +469,9 @@
             "computer_use": {
               "type": "boolean"
             },
+            "concurrent_reasoning_summaries": {
+              "type": "boolean"
+            },
             "connectors": {
               "type": "boolean"
             },
@@ -4838,6 +4841,9 @@
         "computer_use": {
           "type": "boolean"
         },
+        "concurrent_reasoning_summaries": {
+          "type": "boolean"
+        },
         "connectors": {
           "type": "boolean"
         },
diff --git a/codex-rs/core/src/client.rs b/codex-rs/core/src/client.rs
index efc675a0ae..9db8bec7f2 100644
--- a/codex-rs/core/src/client.rs
+++ b/codex-rs/core/src/client.rs
@@ -2052,17 +2052,16 @@ where
                     token_usage,
                     end_turn,
                 }) => {
-                    if let Some(buffer) = output_item_done_buffer.as_mut() {
-                        if !forward_completed_items(&tx_event, &mut items_added, buffer.finish())
+                    if let Some(buffer) = output_item_done_buffer.as_mut()
+                        && !forward_completed_items(&tx_event, &mut items_added, buffer.finish())
                             .await
-                        {
-                            inference_trace_attempt.record_cancelled(
-                                STREAM_DROPPED_REASON,
-                                upstream_request_id,
-                                &items_added,
-                            );
-                            return;
-                        }
+                    {
+                        inference_trace_attempt.record_cancelled(
+                            STREAM_DROPPED_REASON,
+                            upstream_request_id,
+                            &items_added,
+                        );
+                        return;
                     }
                     feedback_tags!(last_model_response_id = &response_id);
                     if let Some(usage) = &token_usage {