iter_bytes() — anthropic-sdk-python Function Reference

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

Function python AnthropicClient AsyncAPI calls 3 called by 3

Entity Profile

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

Dependency Diagram

graph TD
  9f55bd15_7a95_ba28_c590_203ea0be62b2["iter_bytes()"]
  f51bd194_1989_e99a_c3a5_5c461e19050e["SSEDecoder"]
  9f55bd15_7a95_ba28_c590_203ea0be62b2 -->|defined in| f51bd194_1989_e99a_c3a5_5c461e19050e
  92109d5c_b27f_e466_b321_1c4cbdab731c["iter_bytes()"]
  92109d5c_b27f_e466_b321_1c4cbdab731c -->|calls| 9f55bd15_7a95_ba28_c590_203ea0be62b2
  45fe0d69_db3d_a57c_6c23_db57ac73d759["iter_bytes()"]
  45fe0d69_db3d_a57c_6c23_db57ac73d759 -->|calls| 9f55bd15_7a95_ba28_c590_203ea0be62b2
  945cdcce_6566_7ff1_9ea3_601246f05c72["_iter_events()"]
  945cdcce_6566_7ff1_9ea3_601246f05c72 -->|calls| 9f55bd15_7a95_ba28_c590_203ea0be62b2
  1ee4fd43_58e1_ba10_7366_ee4c34d3cf45["_iter_chunks()"]
  9f55bd15_7a95_ba28_c590_203ea0be62b2 -->|calls| 1ee4fd43_58e1_ba10_7366_ee4c34d3cf45
  3f6e6755_7dcb_24fa_f03c_7576f9854d91["decode()"]
  9f55bd15_7a95_ba28_c590_203ea0be62b2 -->|calls| 3f6e6755_7dcb_24fa_f03c_7576f9854d91
  92109d5c_b27f_e466_b321_1c4cbdab731c["iter_bytes()"]
  9f55bd15_7a95_ba28_c590_203ea0be62b2 -->|calls| 92109d5c_b27f_e466_b321_1c4cbdab731c
  style 9f55bd15_7a95_ba28_c590_203ea0be62b2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

src/anthropic/_streaming.py lines 311–319

    def iter_bytes(self, iterator: Iterator[bytes]) -> Iterator[ServerSentEvent]:
        """Given an iterator that yields raw binary data, iterate over it & yield every event encountered"""
        for chunk in self._iter_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