mcp-race-condition-handl-fast-failing-requests-in-streamablehttp-transport--bac25923

THEN Catch anyio.ClosedResourceError in the message router loop to gracefully handle the closed stream. Alternatively, add a small asyncio.sleep(0.1) before early returns in validation functions to allow the router to finish its checkpoint. The first approach is preferred as it directly suppresses the spurious error without introducing artificial delays.

try:
    async for session_message in write_stream_reader:
        # ... existing code ...
except anyio.ClosedResourceError:
    pass