diff --git a/lib/active_agent/providers/open_ai/chat_provider.rb b/lib/active_agent/providers/open_ai/chat_provider.rb
index 4c1bd656..3c23586b 100644
--- a/lib/active_agent/providers/open_ai/chat_provider.rb
+++ b/lib/active_agent/providers/open_ai/chat_provider.rb
@@ -95,6 +95,8 @@ def api_response_normalize(api_response)
         def process_stream_chunk(api_response_event)
           instrument("stream_chunk.active_agent")
 
+          broadcast_stream_open
+
           # Called Multiple Times: [Chunk<T>, T]<Content, ToolsCall>
           case api_response_event.type
           when :chunk