Method test_default_stream_cls

tests/test_client.py:1044–1052

(self, respx_mock: MockRouter, client: OpenAI)

    @pytest.mark.respx(base_url=base_url)
    def test_default_stream_cls(self, respx_mock: MockRouter, client: OpenAI) -> None:
        class Model(BaseModel):
            name: str

        respx_mock.post(class="st">"/foo").mock(return_value=httpx.Response(200, json={class="st">"foo": class="st">"bar"}))

        stream = client.post(class="st">"/foo", cast_to=Model, stream=True, stream_cls=Stream[Model])
        assert isinstance(stream, Stream)
        stream.response.close()

    @pytest.mark.respx(base_url=base_url)
    def test_received_text_for_expected_json(self, respx_mock: MockRouter) -> None: