88
99import httpx
1010import pytest
11+ from respx import MockRouter
1112
1213from tests .utils import assert_matches_type
1314from runloop_api_client import Runloop , AsyncRunloop
@@ -238,15 +239,21 @@ def test_path_params_kill(self, client: Runloop) -> None:
238239 )
239240
240241 @parametrize
241- def test_method_stream_stdout_updates (self , client : Runloop ) -> None :
242+ def test_method_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
243+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
244+ return_value = httpx .Response (200 )
245+ )
242246 execution_stream = client .devboxes .executions .stream_stdout_updates (
243247 execution_id = "execution_id" ,
244248 devbox_id = "devbox_id" ,
245249 )
246250 execution_stream .response .close ()
247251
248252 @parametrize
249- def test_method_stream_stdout_updates_with_all_params (self , client : Runloop ) -> None :
253+ def test_method_stream_stdout_updates_with_all_params (self , client : Runloop , respx_mock : MockRouter ) -> None :
254+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
255+ return_value = httpx .Response (200 )
256+ )
250257 execution_stream = client .devboxes .executions .stream_stdout_updates (
251258 execution_id = "execution_id" ,
252259 devbox_id = "devbox_id" ,
@@ -255,7 +262,10 @@ def test_method_stream_stdout_updates_with_all_params(self, client: Runloop) ->
255262 execution_stream .response .close ()
256263
257264 @parametrize
258- def test_raw_response_stream_stdout_updates (self , client : Runloop ) -> None :
265+ def test_raw_response_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
266+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
267+ return_value = httpx .Response (200 )
268+ )
259269 response = client .devboxes .executions .with_raw_response .stream_stdout_updates (
260270 execution_id = "execution_id" ,
261271 devbox_id = "devbox_id" ,
@@ -266,7 +276,10 @@ def test_raw_response_stream_stdout_updates(self, client: Runloop) -> None:
266276 stream .close ()
267277
268278 @parametrize
269- def test_streaming_response_stream_stdout_updates (self , client : Runloop ) -> None :
279+ def test_streaming_response_stream_stdout_updates (self , client : Runloop , respx_mock : MockRouter ) -> None :
280+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
281+ return_value = httpx .Response (200 )
282+ )
270283 with client .devboxes .executions .with_streaming_response .stream_stdout_updates (
271284 execution_id = "execution_id" ,
272285 devbox_id = "devbox_id" ,
@@ -742,15 +755,23 @@ async def test_path_params_kill(self, async_client: AsyncRunloop) -> None:
742755 )
743756
744757 @parametrize
745- async def test_method_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
758+ async def test_method_stream_stdout_updates (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
759+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
760+ return_value = httpx .Response (200 )
761+ )
746762 execution_stream = await async_client .devboxes .executions .stream_stdout_updates (
747763 execution_id = "execution_id" ,
748764 devbox_id = "devbox_id" ,
749765 )
750766 await execution_stream .response .aclose ()
751767
752768 @parametrize
753- async def test_method_stream_stdout_updates_with_all_params (self , async_client : AsyncRunloop ) -> None :
769+ async def test_method_stream_stdout_updates_with_all_params (
770+ self , async_client : AsyncRunloop , respx_mock : MockRouter
771+ ) -> None :
772+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
773+ return_value = httpx .Response (200 )
774+ )
754775 execution_stream = await async_client .devboxes .executions .stream_stdout_updates (
755776 execution_id = "execution_id" ,
756777 devbox_id = "devbox_id" ,
@@ -759,7 +780,10 @@ async def test_method_stream_stdout_updates_with_all_params(self, async_client:
759780 await execution_stream .response .aclose ()
760781
761782 @parametrize
762- async def test_raw_response_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
783+ async def test_raw_response_stream_stdout_updates (self , async_client : AsyncRunloop , respx_mock : MockRouter ) -> None :
784+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
785+ return_value = httpx .Response (200 )
786+ )
763787 response = await async_client .devboxes .executions .with_raw_response .stream_stdout_updates (
764788 execution_id = "execution_id" ,
765789 devbox_id = "devbox_id" ,
@@ -770,7 +794,12 @@ async def test_raw_response_stream_stdout_updates(self, async_client: AsyncRunlo
770794 await stream .close ()
771795
772796 @parametrize
773- async def test_streaming_response_stream_stdout_updates (self , async_client : AsyncRunloop ) -> None :
797+ async def test_streaming_response_stream_stdout_updates (
798+ self , async_client : AsyncRunloop , respx_mock : MockRouter
799+ ) -> None :
800+ respx_mock .get ("/v1/devboxes/devbox_id/executions/execution_id/stream_stdout_updates" ).mock (
801+ return_value = httpx .Response (200 )
802+ )
774803 async with async_client .devboxes .executions .with_streaming_response .stream_stdout_updates (
775804 execution_id = "execution_id" ,
776805 devbox_id = "devbox_id" ,
0 commit comments