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
  ba051e44_a190_9141_551c_ce3d77cfeefc["__stream__()"]
  e621e870_ca7f_408e_c8bb_3d408ede66a4["MessageStream"]
  ba051e44_a190_9141_551c_ce3d77cfeefc -->|defined in| e621e870_ca7f_408e_c8bb_3d408ede66a4
  7a9a7646_ea92_5eb4_1131_e001c6adde71["accumulate_event()"]
  ba051e44_a190_9141_551c_ce3d77cfeefc -->|calls| 7a9a7646_ea92_5eb4_1131_e001c6adde71
  65667782_04ce_8584_0e7c_871a0bb8dd1c["build_events()"]
  ba051e44_a190_9141_551c_ce3d77cfeefc -->|calls| 65667782_04ce_8584_0e7c_871a0bb8dd1c
  style ba051e44_a190_9141_551c_ce3d77cfeefc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/lib/streaming/_messages.py lines 128–138

    def __stream__(self) -> Iterator[ParsedMessageStreamEvent[ResponseFormatT]]:
        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