tests/test_llm_anthropic_streaming.py

_cfg · function · L11-L17 — def _cfg()
_install_stream · function · L20-L34 — def _install_stream(monkeypatch, events)
post_sse · function · L23-L26 — def post_sse(url, payload, headers, timeout, on_event)
test_anthropic_stream_forwards_text_and_merges_usage · function · L37-L78 — def test_anthropic_stream_forwards_text_and_merges_usage(monkeypatch)
test_anthropic_stream_reassembles_tool_input · function · L81-L124 — def test_anthropic_stream_reassembles_tool_input(monkeypatch)
test_anthropic_stream_error_after_start_does_not_replay · function · L127-L145 — def test_anthropic_stream_error_after_start_does_not_replay(monkeypatch)
post_sse · function · L130-L132 — def post_sse(_url, _payload, _headers, _timeout, on_event)
test_anthropic_stream_start_failure_falls_back_to_blocking · function · L148-L173 — def test_anthropic_stream_start_failure_falls_back_to_blocking(monkeypatch)
post_sse · function · L151-L152 — def post_sse(*_args)
post_json · function · L154-L160 — def post_json(_url, payload, _headers, _timeout)
test_stream_disabled_by_env_never_opens_an_sse_connection · function · L176-L202 — def test_stream_disabled_by_env_never_opens_an_sse_connection(monkeypatch)
post_json · function · L182-L188 — def post_json(_url, payload, _headers, _timeout)
test_streaming_and_blocking_normalize_the_same_reply · function · L271-L297 — def test_streaming_and_blocking_normalize_the_same_reply(monkeypatch)
test_unrecognized_blocks_survive_into_the_next_turn · function · L300-L344 — def test_unrecognized_blocks_survive_into_the_next_turn(monkeypatch)
test_thinking_blocks_reassemble_with_their_signature · function · L347-L387 — def test_thinking_blocks_reassemble_with_their_signature(monkeypatch)
test_unparsed_tool_input_stays_an_object_on_the_wire · function · L390-L420 — def test_unparsed_tool_input_stays_an_object_on_the_wire(monkeypatch)
test_a_stream_without_a_stop_reason_still_names_one · function · L423-L447 — def test_a_stream_without_a_stop_reason_still_names_one(monkeypatch)