Skip to content

Commit 427a688

Browse files
committed
Add broadcast for stream open in process_stream_chunk
1 parent 91e7006 commit 427a688

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

lib/active_agent/providers/open_ai/chat_provider.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,8 @@ def api_response_normalize(api_response)
9595
def process_stream_chunk(api_response_event)
9696
instrument("stream_chunk.active_agent")
9797

98+
broadcast_stream_open
99+
98100
# Called Multiple Times: [Chunk<T>, T]<Content, ToolsCall>
99101
case api_response_event.type
100102
when :chunk

0 commit comments

Comments
 (0)