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 5750c32 commit f1a973aCopy full SHA for f1a973a
src/mcp/shared/session.py
@@ -292,7 +292,7 @@ async def receive_response(
292
assert request is not None
293
294
try:
295
- with anyio.fail_after(timeout):
+ with anyio.move_on_after(timeout):
296
return await receive_stream.receive()
297
except anyio.EndOfStream:
298
raise McpError(
@@ -301,8 +301,6 @@ async def receive_response(
301
message=("Connection closed"),
302
)
303
304
- except TimeoutError:
305
- return None
306
307
async def handle_response(self, message: JSONRPCResponse | JSONRPCError) -> bool:
308
send_stream, _ = self._response_streams.get(message.id, [None, None])
0 commit comments