Remove timeouts

Author: ishymko

src/a2a/client/transports/jsonrpc.py

@@ -125,7 +125,6 @@ async def send_message_streaming(
         async for event in self._send_stream_request(
             payload,
             http_kwargs=modified_kwargs,
-            timeout=self.httpx_client.timeout.as_dict().get('read', None),
         ):
             yield event
 
@@ -374,7 +373,6 @@ async def subscribe(
         async for event in self._send_stream_request(
             payload,
             http_kwargs=modified_kwargs,
-            timeout=self.httpx_client.timeout.as_dict().get('read', None),
         ):
             yield event
 
@@ -486,7 +484,6 @@ async def _send_stream_request(
     ) -> AsyncGenerator[StreamResponse]:
         final_kwargs = dict(http_kwargs or {})
         final_kwargs.update(kwargs)
-        final_kwargs.setdefault('timeout', None)
         headers = dict(self.httpx_client.headers.items())
         headers.update(final_kwargs.get('headers', {}))
         final_kwargs['headers'] = headers

src/a2a/client/transports/rest.py

@@ -102,7 +102,6 @@ async def send_message_streaming(
             '/v1/message:stream',
             http_kwargs=modified_kwargs,
             json=payload,
-            timeout=self.httpx_client.timeout.as_dict().get('read', None),
         ):
             yield event
 
@@ -320,7 +319,6 @@ async def subscribe(
             'GET',
             f'/v1/tasks/{request.id}:subscribe',
             http_kwargs=modified_kwargs,
-            timeout=self.httpx_client.timeout.as_dict().get('read', None),
         ):
             yield event
 
@@ -430,7 +428,6 @@ async def _send_stream_request(
     ) -> AsyncGenerator[StreamResponse]:
         final_kwargs = dict(http_kwargs or {})
         final_kwargs.update(kwargs)
-        final_kwargs.setdefault('timeout', None)
 
         async for sse_data in send_http_stream_request(
             self.httpx_client,