_aiter_chunks() — anthropic-sdk-python Function Reference

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

Function python AnthropicClient SyncAPI called by 1

Entity Profile

AnthropicClient→ SyncAPI→ _aiter_chunks() — anthropic-sdk-python Function Reference

Dependency Diagram

graph TD
  b961b18a_baa9_de62_39dc_b7271a4ee103["_aiter_chunks()"]
  f51bd194_1989_e99a_c3a5_5c461e19050e["SSEDecoder"]
  b961b18a_baa9_de62_39dc_b7271a4ee103 -->|defined in| f51bd194_1989_e99a_c3a5_5c461e19050e
  484b3879_bf87_4601_d355_eb6e18237685["aiter_bytes()"]
  484b3879_bf87_4601_d355_eb6e18237685 -->|calls| b961b18a_baa9_de62_39dc_b7271a4ee103
  style b961b18a_baa9_de62_39dc_b7271a4ee103 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/_streaming.py lines 343–353

    async def _aiter_chunks(self, iterator: AsyncIterator[bytes]) -> AsyncIterator[bytes]:
        """Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunks"""
        data = b""
        async for chunk in iterator:
            for line in chunk.splitlines(keepends=True):
                data += line
                if data.endswith((b"\r\r", b"\n\n", b"\r\n\r\n")):
                    yield data
                    data = b""
        if data:
            yield data