Method __init__

src/opencode_ai/_streaming.py:91–102

(
        self,
        *,
        cast_to: type[_T],
        response: httpx.Response,
        client: AsyncOpencode,
    )

    _decoder: SSEDecoder | SSEBytesDecoder

    def __init__(
        self,
        *,
        cast_to: type[_T],
        response: httpx.Response,
        client: AsyncOpencode,
    ) -> None:
        self.response = response
        self._cast_to = cast_to
        self._client = client
        self._decoder = client._make_sse_decoder()
        self._iterator = self.__stream__()

    async def __anext__(self) -> _T:
        return await self._iterator.__anext__()