From def4a996c4c8a59fc223c754aeabc05256ebbdb3 Mon Sep 17 00:00:00 2001
From: jif-oai <jif@openai.com>
Date: Thu, 13 Nov 2025 15:56:18 +0100
Subject: [PATCH] Tests 2

---
 codex-rs/core/src/client/responses.rs | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/codex-rs/core/src/client/responses.rs b/codex-rs/core/src/client/responses.rs
index a914475052..777cb68a86 100644
--- a/codex-rs/core/src/client/responses.rs
+++ b/codex-rs/core/src/client/responses.rs
@@ -352,7 +352,17 @@ impl ModelClient {
             Ok(resp) if resp.status().is_success() => {
                 let (tx_event, rx_event) = mpsc::channel::<Result<ResponseEvent>>(1600);
 
-                if let Some(snapshot) = parse_rate_limit_snapshot(resp.headers())
+                // Always emit a RateLimits event at the start of a successful
+                // stream so downstream consumers (Session) can surface an
+                // initial TokenCount snapshot, even when the provider does not
+                // send explicit rate limit headers.
+                let snapshot = parse_rate_limit_snapshot(resp.headers()).or_else(|| {
+                    Some(RateLimitSnapshot {
+                        primary: None,
+                        secondary: None,
+                    })
+                });
+                if let Some(snapshot) = snapshot
                     && tx_event
                         .send(Ok(ResponseEvent::RateLimits(snapshot)))
                         .await