make BaseClientSession inherit from CommonBaseSession

Author: sreenithi

src/mcp/client/base_client_session.py

@@ -2,12 +2,20 @@
 from typing import Any
 
 from mcp import types
-from mcp.shared.session import ProgressFnT
+from mcp.shared.session import CommonBaseSession, ProgressFnT
 from mcp.types._types import RequestParamsMeta
 
 # from mcp.shared.session import CommonBaseSession
 
-class BaseClientSession:
+class BaseClientSession(
+    CommonBaseSession[
+        types.ClientRequest,
+        types.ClientNotification,
+        types.ClientResult,
+        types.ServerRequest,
+        types.ServerNotification,
+    ]
+):
     """Base class for client transport sessions.
 
     The class provides all the methods that a client session should implement,
@@ -24,17 +32,6 @@ async def send_ping(self, *, meta: RequestParamsMeta | None = None) -> types.Emp
         """Send a ping request."""
         raise NotImplementedError
 
-    @abstractmethod
-    async def send_progress_notification(
-        self,
-        progress_token: types.ProgressToken,
-        progress: float,
-        total: float | None = None,
-        message: str | None = None,
-    ) -> None:
-        """Sends a progress notification for a request that is currently being processed."""
-        raise NotImplementedError
-
     @abstractmethod
     async def list_resources(self, *, params: types.PaginatedRequestParams | None = None) -> types.ListResourcesResult:
         """Send a resources/list request.

src/mcp/shared/session.py

@@ -185,6 +185,7 @@ def __init__(
         self._write_stream = write_stream
         self._session_read_timeout_seconds = read_timeout_seconds
         self._response_streams = {}
+        self._task_group = anyio.create_task_group()
 
     @abstractmethod
     async def send_request(