test(streamable-http): cover closed read stream cleanup

Author: Jianke LIN

tests/client/test_streamable_http.py

@@ -106,6 +106,26 @@ async def test_sse_response_disconnect_before_any_event_id_fails_request() -> No
     assert message.message.error.code == CONNECTION_CLOSED
 
 
+@pytest.mark.anyio
+async def test_sse_response_disconnect_ignores_closed_read_stream() -> None:
+    transport = StreamableHTTPTransport("http://example.com/mcp")
+    async with httpx.AsyncClient() as client:
+        read_stream_writer, read_stream = create_context_streams[SessionMessage | Exception](1)
+        request = JSONRPCRequest(jsonrpc="2.0", id=1, method="tools/call", params={"name": "noop", "arguments": {}})
+        ctx = RequestContext(
+            client=client,
+            session_id=None,
+            session_message=SessionMessage(request),
+            metadata=None,
+            read_stream_writer=read_stream_writer,
+        )
+        response = httpx.Response(200, headers={"content-type": "text/event-stream"}, content=b"")
+
+        async with read_stream_writer, read_stream:
+            await read_stream.aclose()
+            await transport._handle_sse_response(response, ctx)
+
+
 @pytest.mark.anyio
 async def test_post_request_merges_per_message_metadata_headers() -> None:
     """`ClientMessageMetadata.headers` on a `SessionMessage` are merged into the outgoing POST headers