(
body: dict, stream_chunks: list[bytes], transport: str
)
| 724 | |
| 725 | |
| 726 | def _capture_streaming( |
| 727 | body: dict, stream_chunks: list[bytes], transport: str |
| 728 | ) -> dict[str, Any]: |
| 729 | if not _capture_enabled(): |
| 730 | return {} |
| 731 | text, calls, finish = parse_stream_assistant_content(stream_chunks, transport) |
| 732 | return _build_capture_dict(body, text, calls, finish) |
| 733 | |
| 734 | |
| 735 | class UpstreamSemanticCompressor: |