We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 107fbdf commit 34d2735Copy full SHA for 34d2735
src/a2a/client/transports/jsonrpc.py
@@ -147,13 +147,13 @@ async def send_message_streaming(
147
context,
148
)
149
150
- modified_kwargs.setdefault('timeout', self.httpx_client.timeout.as_dict().get('read', None))
+ modified_kwargs.setdefault(
151
+ 'timeout', self.httpx_client.timeout.as_dict().get('read', None)
152
+ )
153
headers = dict(self.httpx_client.headers.items())
154
headers.update(modified_kwargs.get('headers', {}))
155
modified_kwargs['headers'] = headers
156
-
157
async with aconnect_sse(
158
self.httpx_client,
159
'POST',
0 commit comments