Function make_stream_iterator

tests/test_streaming.py:284–302

(
    content: Iterator[bytes],
    *,
    sync: bool,
    client: Anthropic,
    async_client: AsyncAnthropic,
)

# Unlike make_event_iterator which only parses SSE events using _iter_events(),
# this helper uses __stream__() to process the full stream pipeline including
# parsing message objects and converting error events into raised exceptions.
def make_stream_iterator(
    content: Iterator[bytes],
    *,
    sync: bool,
    client: Anthropic,
    async_client: AsyncAnthropic,
) -> AsyncIterator[object] | Iterator[object]:
    if sync:
        return Stream(
            cast_to=object,
            client=client,
            response=httpx.Response(200, content=content, request=httpx.Request("GET", "https://example.com")),
        ).__stream__()

    return AsyncStream(
        cast_to=object,
        client=async_client,
        response=httpx.Response(200, content=to_aiter(content), request=httpx.Request("GET", "https://example.com")),
    ).__stream__()