Add coverage pragmas for SSE reconnection code paths

Author: felixweinberger

src/mcp/client/streamable_http.py

@@ -408,19 +408,19 @@ async def _handle_sse_response(
                 if is_complete:
                     await response.aclose()
                     break
-        except Exception as e:
+        except Exception as e:  # pragma: no cover
             logger.exception("Error reading SSE stream:")
             # Don't send exception if we can reconnect
             if not (has_priming_event and last_event_id):
                 await ctx.read_stream_writer.send(e)
 
         # Auto-reconnect if stream ended without completion and we have priming event
         if not is_complete and has_priming_event and last_event_id:
-            await self._attempt_sse_reconnection(ctx, last_event_id, attempt)
+            await self._attempt_sse_reconnection(ctx, last_event_id, attempt)  # pragma: no cover
 
         return has_priming_event, last_event_id
 
-    async def _attempt_sse_reconnection(
+    async def _attempt_sse_reconnection(  # pragma: no cover
         self,
         ctx: RequestContext,
         last_event_id: str,

src/mcp/server/streamable_http_manager.py

@@ -294,8 +294,8 @@ async def close_sse_stream(self, session_id: str, request_id: str | int) -> bool
         Returns:
             True if the stream was found and closed, False otherwise
         """
-        if session_id not in self._server_instances:
+        if session_id not in self._server_instances:  # pragma: no cover
             return False
-        transport = self._server_instances[session_id]
-        await transport.close_sse_stream(request_id)
-        return True
+        transport = self._server_instances[session_id]  # pragma: no cover
+        await transport.close_sse_stream(request_id)  # pragma: no cover
+        return True  # pragma: no cover