_iter_chunks() — anthropic-sdk-python Function Reference

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

Function python AnthropicClient SyncAPI called by 1

Entity Profile

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

Dependency Diagram

graph TD
  1ee4fd43_58e1_ba10_7366_ee4c34d3cf45["_iter_chunks()"]
  f51bd194_1989_e99a_c3a5_5c461e19050e["SSEDecoder"]
  1ee4fd43_58e1_ba10_7366_ee4c34d3cf45 -->|defined in| f51bd194_1989_e99a_c3a5_5c461e19050e
  9f55bd15_7a95_ba28_c590_203ea0be62b2["iter_bytes()"]
  9f55bd15_7a95_ba28_c590_203ea0be62b2 -->|calls| 1ee4fd43_58e1_ba10_7366_ee4c34d3cf45
  style 1ee4fd43_58e1_ba10_7366_ee4c34d3cf45 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/_streaming.py lines 321–331

    def _iter_chunks(self, iterator: Iterator[bytes]) -> Iterator[bytes]:
        """Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunks"""
        data = b""
        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