From 427a688babe23b315124473c150ce9841a0692ea Mon Sep 17 00:00:00 2001 From: Neil Jobbins <3514122+TheRealNeil@users.noreply.github.com> Date: Sat, 7 Feb 2026 18:57:20 -0800 Subject: [PATCH] Add broadcast for stream open in process_stream_chunk --- lib/active_agent/providers/open_ai/chat_provider.rb | 2 ++ 1 file changed, 2 insertions(+) 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] case api_response_event.type when :chunk