66from typing import Any , cast
77from unittest .mock import Mock , patch
88
9+ from respx import MockRouter
10+
911import httpx
1012import pytest
1113
@@ -238,15 +240,21 @@ def test_path_params_kill(self, client: Runloop) -> None:
238240 )
239241
240242 @parametrize
241- def test_method_stream_stdout_updates (self , client : Runloop ) -> None :
243+ def test_method_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
244+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
245+ return_value = httpx .Response (200 )
246+ )
242247 execution_stream = client .devboxes .executions .stream_stdout_updates (
243248 execution_id = "execution_id" ,
244249 devbox_id = "devbox_id" ,
245250 )
246251 execution_stream .response .close ()
247252
248253 @parametrize
249- def test_method_stream_stdout_updates_with_all_params (self , client : Runloop ) -> None :
254+ def test_method_stream_stdout_updates_with_all_params (self , client : Runloop , respx_mock : MockRouter ) -> None :
255+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
256+ return_value = httpx .Response (200 )
257+ )
250258 execution_stream = client .devboxes .executions .stream_stdout_updates (
251259 execution_id = "execution_id" ,
252260 devbox_id = "devbox_id" ,
@@ -255,7 +263,10 @@ def test_method_stream_stdout_updates_with_all_params(self, client: Runloop) ->
255263 execution_stream .response .close ()
256264
257265 @parametrize
258- def test_raw_response_stream_stdout_updates (self , client : Runloop ) -> None :
266+ def test_raw_response_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
267+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
268+ return_value = httpx .Response (200 )
269+ )
259270 response = client .devboxes .executions .with_raw_response .stream_stdout_updates (
260271 execution_id = "execution_id" ,
261272 devbox_id = "devbox_id" ,
@@ -266,7 +277,10 @@ def test_raw_response_stream_stdout_updates(self, client: Runloop) -> None:
266277 stream .close ()
267278
268279 @parametrize
269- def test_streaming_response_stream_stdout_updates (self , client : Runloop ) -> None :
280+ def test_streaming_response_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
281+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
282+ return_value = httpx .Response (200 )
283+ )
270284 with client .devboxes .executions .with_streaming_response .stream_stdout_updates (
271285 execution_id = "execution_id" ,
272286 devbox_id = "devbox_id" ,
@@ -742,15 +756,21 @@ async def test_path_params_kill(self, async_client: AsyncRunloop) -> None:
742756 )
743757
744758 @parametrize
745- async def test_method_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
759+ async def test_method_stream_stdout_updates (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
760+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
761+ return_value = httpx .Response (200 )
762+ )
746763 execution_stream = await async_client .devboxes .executions .stream_stdout_updates (
747764 execution_id = "execution_id" ,
748765 devbox_id = "devbox_id" ,
749766 )
750767 await execution_stream .response .aclose ()
751768
752769 @parametrize
753- async def test_method_stream_stdout_updates_with_all_params (self , async_client : AsyncRunloop ) -> None :
770+ async def test_method_stream_stdout_updates_with_all_params (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
771+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
772+ return_value = httpx .Response (200 )
773+ )
754774 execution_stream = await async_client .devboxes .executions .stream_stdout_updates (
755775 execution_id = "execution_id" ,
756776 devbox_id = "devbox_id" ,
@@ -759,7 +779,10 @@ async def test_method_stream_stdout_updates_with_all_params(self, async_client:
759779 await execution_stream .response .aclose ()
760780
761781 @parametrize
762- async def test_raw_response_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
782+ async def test_raw_response_stream_stdout_updates (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
783+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
784+ return_value = httpx .Response (200 )
785+ )
763786 response = await async_client .devboxes .executions .with_raw_response .stream_stdout_updates (
764787 execution_id = "execution_id" ,
765788 devbox_id = "devbox_id" ,
@@ -770,7 +793,10 @@ async def test_raw_response_stream_stdout_updates(self, async_client: AsyncRunlo
770793 await stream .close ()
771794
772795 @parametrize
773- async def test_streaming_response_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
796+ async def test_streaming_response_stream_stdout_updates (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
797+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
798+ return_value = httpx .Response (200 )
799+ )
774800 async with async_client .devboxes .executions .with_streaming_response .stream_stdout_updates (
775801 execution_id = "execution_id" ,
776802 devbox_id = "devbox_id" ,
0 commit comments