agentjido / req_llm / fe2fc913f969b3d215c2b7d6d3c4ea28b4a8ac4d

49%

push

github

feat: add StreamResponse.process_stream/2 for real-time callbacks (#178)

Adds process_stream/2 function to StreamResponse that enables real-time
stream processing with incremental callbacks, avoiding double-stream
consumption bugs.

Features:
  - on_result callback: fires immediately for each content chunk
  - on_thinking callback: fires immediately for each thinking chunk
  - on_tool_call callback: fires after stream completes with
reconstructed tool calls
  - Single-pass stream consumption using Enum.reduce (no upfront
Enum.to_list)
  - All callbacks are optional
  - Accumulate text_content and thinking_content during stream process
  - Build complete Message struct with all content parts
  - Await metadata_task and include usage/finish_reason in response

Co-authored-by: Mike Hostetler <84222+mikehostetler@users.noreply.github.com>

47 of 50 new or added lines in 1 file covered. (94.0%)

3995 of 7566 relevant lines covered (52.8%)

354.15 hits per line