aiter_bytes() — anthropic-sdk-python Function Reference

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

Function python AnthropicClient AsyncAPI calls 3 called by 5

Entity Profile

AnthropicClient→ AsyncAPI→ aiter_bytes() — anthropic-sdk-python Function Reference

Dependency Diagram

graph TD
  484b3879_bf87_4601_d355_eb6e18237685["aiter_bytes()"]
  f51bd194_1989_e99a_c3a5_5c461e19050e["SSEDecoder"]
  484b3879_bf87_4601_d355_eb6e18237685 -->|defined in| f51bd194_1989_e99a_c3a5_5c461e19050e
  f57cbcef_49ce_e01d_8bfb_5b3ee825c0b0["aiter_bytes()"]
  f57cbcef_49ce_e01d_8bfb_5b3ee825c0b0 -->|calls| 484b3879_bf87_4601_d355_eb6e18237685
  7e30c80b_9b40_d863_b9d5_a0e681fe7e3a["aiter_bytes()"]
  7e30c80b_9b40_d863_b9d5_a0e681fe7e3a -->|calls| 484b3879_bf87_4601_d355_eb6e18237685
  368da297_37b7_ab67_d177_ee29db8d5086["_parse()"]
  368da297_37b7_ab67_d177_ee29db8d5086 -->|calls| 484b3879_bf87_4601_d355_eb6e18237685
  681781bd_bf17_30fc_c2f4_93e275856355["iter_bytes()"]
  681781bd_bf17_30fc_c2f4_93e275856355 -->|calls| 484b3879_bf87_4601_d355_eb6e18237685
  d5539735_c422_7406_d09e_758baa2aeb5a["_iter_events()"]
  d5539735_c422_7406_d09e_758baa2aeb5a -->|calls| 484b3879_bf87_4601_d355_eb6e18237685
  b961b18a_baa9_de62_39dc_b7271a4ee103["_aiter_chunks()"]
  484b3879_bf87_4601_d355_eb6e18237685 -->|calls| b961b18a_baa9_de62_39dc_b7271a4ee103
  3f6e6755_7dcb_24fa_f03c_7576f9854d91["decode()"]
  484b3879_bf87_4601_d355_eb6e18237685 -->|calls| 3f6e6755_7dcb_24fa_f03c_7576f9854d91
  f57cbcef_49ce_e01d_8bfb_5b3ee825c0b0["aiter_bytes()"]
  484b3879_bf87_4601_d355_eb6e18237685 -->|calls| f57cbcef_49ce_e01d_8bfb_5b3ee825c0b0
  style 484b3879_bf87_4601_d355_eb6e18237685 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/_streaming.py lines 333–341

    async def aiter_bytes(self, iterator: AsyncIterator[bytes]) -> AsyncIterator[ServerSentEvent]:
        """Given an iterator that yields raw binary data, iterate over it & yield every event encountered"""
        async for chunk in self._aiter_chunks(iterator):
            # Split before decoding so splitlines() only uses \r and \n
            for raw_line in chunk.splitlines():
                line = raw_line.decode("utf-8")
                sse = self.decode(line)
                if sse:
                    yield sse