stream() — anthropic-sdk-python Function Reference

Architecture documentation for the __stream__() function in _messages.py from the anthropic-sdk-python codebase.

Function python StreamProtocol AsyncStreaming calls 2

Entity Profile

StreamProtocol→ AsyncStreaming→ __stream__() — anthropic-sdk-python Function Reference

Dependency Diagram

graph TD
  cad54414_ccd6_b061_6332_68338c7a97aa["__stream__()"]
  4f4cec09_94d5_eeb6_5c17_29d2af98f435["AsyncMessageStream"]
  cad54414_ccd6_b061_6332_68338c7a97aa -->|defined in| 4f4cec09_94d5_eeb6_5c17_29d2af98f435
  7a9a7646_ea92_5eb4_1131_e001c6adde71["accumulate_event()"]
  cad54414_ccd6_b061_6332_68338c7a97aa -->|calls| 7a9a7646_ea92_5eb4_1131_e001c6adde71
  65667782_04ce_8584_0e7c_871a0bb8dd1c["build_events()"]
  cad54414_ccd6_b061_6332_68338c7a97aa -->|calls| 65667782_04ce_8584_0e7c_871a0bb8dd1c
  style cad54414_ccd6_b061_6332_68338c7a97aa fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/lib/streaming/_messages.py lines 276–286

    async def __stream__(self) -> AsyncIterator[ParsedMessageStreamEvent[ResponseFormatT]]:
        async for sse_event in self._raw_stream:
            self.__final_message_snapshot = accumulate_event(
                event=sse_event,
                current_snapshot=self.__final_message_snapshot,
                output_format=self.__output_format,
            )

            events_to_fire = build_events(event=sse_event, message_snapshot=self.current_message_snapshot)
            for event in events_to_fire:
                yield event