style: Trim trailing blank lines to satisfy end-of-file-fixer hook

Author: wukath

src/mcp/client/streamable_http.py

@@ -76,7 +76,6 @@ def _unwrap_exception(exc: BaseException) -> BaseException:
     return exc
 
 
-
 @dataclass
 class RequestContext:
     """Context for a request operation."""
@@ -248,7 +247,6 @@ async def handle_get_stream(self, client: httpx2.AsyncClient, read_stream_writer
                 attempt += 1
                 last_exc = exc
 
-
             if attempt >= MAX_RECONNECTION_ATTEMPTS:
                 logger.debug(f"GET stream max reconnection attempts ({MAX_RECONNECTION_ATTEMPTS}) exceeded")
                 raise StreamableHTTPError(
@@ -467,7 +465,6 @@ async def _handle_sse_response(
         except httpx2.HTTPError:
             logger.debug("SSE stream ended", exc_info=True)  # pragma: lax no cover
 
-
         # Stream ended without response - reconnect if we received an event with ID
         if last_event_id is not None:
             logger.info("SSE stream disconnected, reconnecting...")
@@ -554,7 +551,6 @@ async def _handle_reconnection(
             # Try to reconnect again if we still have an event ID
             await self._handle_reconnection(ctx, last_event_id, retry_interval_ms, attempt + 1)
 
-
     async def post_writer(
         self,
         client: httpx2.AsyncClient,
@@ -744,4 +740,3 @@ def start_get_stream() -> None:
         if isinstance(unwrapped, StreamableHTTPError):
             raise unwrapped from exc
         raise
-

tests/shared/test_streamable_http.py

@@ -2339,15 +2339,17 @@ async def test_streamable_http_client_reconnect_failure_propagates_error() -> No
         "content-type": "application/json",
         "mcp-session-id": "test-session",
     }
-    mock_response.aread.return_value = json.dumps({
-        "jsonrpc": "2.0",
-        "id": 1,
-        "result": {
-            "protocolVersion": "2025-06-18",
-            "capabilities": {},
-            "serverInfo": {"name": "test-server", "version": "1.0"},
+    mock_response.aread.return_value = json.dumps(
+        {
+            "jsonrpc": "2.0",
+            "id": 1,
+            "result": {
+                "protocolVersion": "2025-06-18",
+                "capabilities": {},
+                "serverInfo": {"name": "test-server", "version": "1.0"},
+            },
         }
-    }).encode("utf-8")
+    ).encode("utf-8")
 
     mock_initialized_response = AsyncMock(spec=httpx2.Response)
     mock_initialized_response.status_code = 202
@@ -2361,47 +2363,50 @@ async def mock_stream(*args: Any, **kwargs: Any):
 
     client.stream = mock_stream
 
-
     # Mock client.sse to raise httpx2.HTTPError
     client.sse.side_effect = httpx2.HTTPError("SSE connection refused")
 
     # Patch anyio.sleep to avoid waiting during reconnect attempts
     with patch("mcp.client.streamable_http.anyio.sleep", new_callable=AsyncMock) as mock_sleep:
         with pytest.raises(StreamableHTTPError) as exc_info:
             with anyio.fail_after(5):
-                async with streamable_http_client("http://localhost:8000/mcp", http_client=client) as (read_stream, write_stream):
+                async with streamable_http_client("http://localhost:8000/mcp", http_client=client) as (
+                    read_stream,
+                    write_stream,
+                ):
                     # Send initialize message
-                    await write_stream.send(SessionMessage(
-                        types.JSONRPCRequest(
-                            jsonrpc="2.0",
-                            id=1,
-                            method="initialize",
-                            params={
-                                "protocolVersion": "2025-06-18",
-                                "capabilities": {},
-                                "clientInfo": {"name": "test-client", "version": "1.0"},
-                            },
+                    await write_stream.send(
+                        SessionMessage(
+                            types.JSONRPCRequest(
+                                jsonrpc="2.0",
+                                id=1,
+                                method="initialize",
+                                params={
+                                    "protocolVersion": "2025-06-18",
+                                    "capabilities": {},
+                                    "clientInfo": {"name": "test-client", "version": "1.0"},
+                                },
+                            )
                         )
-                    ))
+                    )
 
                     # Receive the response
                     await read_stream.receive()
 
                     # Send notifications/initialized (which will trigger start_get_stream)
-                    await write_stream.send(SessionMessage(
-                        types.JSONRPCNotification(
-                            jsonrpc="2.0",
-                            method="notifications/initialized",
+                    await write_stream.send(
+                        SessionMessage(
+                            types.JSONRPCNotification(
+                                jsonrpc="2.0",
+                                method="notifications/initialized",
+                            )
                         )
-                    ))
+                    )
 
                     # Wait for the task group to fail
                     event = anyio.Event()
                     await event.wait()
 
-
         assert "Failed to connect to GET stream" in str(exc_info.value)
         assert client.sse.call_count == 2
         mock_sleep.assert_called_once_with(1.0)
-
-