We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f891016 commit c3abc89Copy full SHA for c3abc89
src/mcp/server/streamable_http.py
@@ -1015,7 +1015,7 @@ async def message_router():
1015
try:
1016
# Send both the message and the event ID
1017
await self._request_streams[request_stream_id][0].send(EventMessage(message, event_id))
1018
- except (anyio.BrokenResourceError, anyio.ClosedResourceError):
+ except (anyio.BrokenResourceError, anyio.ClosedResourceError): # pragma: lax no cover
1019
# Stream might be closed, remove from registry
1020
self._request_streams.pop(request_stream_id, None)
1021
else:
0 commit comments