Method __init__

src/opencode_ai/_streaming.py:28–39

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

    _decoder: SSEBytesDecoder

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

    def __next__(self) -> _T:
        return self._iterator.__next__()