Fix deprecation warning

modelcontextprotocol · Dec 21, 2024 · 52e69ef · 52e69ef
1 parent 37f6a32
commit 52e69ef
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/mcp/server/sse.py b/src/mcp/server/sse.py
@@ -102,9 +102,9 @@ async def connect_sse(self, scope: Scope, receive: Receive, send: Send):
         self._read_stream_writers[session_id] = read_stream_writer
         logger.debug(f"Created new session with ID: {session_id}")
 
-        sse_stream_writer, sse_stream_reader = anyio.create_memory_object_stream(
-            0, dict[str, Any]
-        )
+        sse_stream_writer, sse_stream_reader = anyio.create_memory_object_stream[
+            dict[str, Any]
+        ](0)
 
         async def sse_writer():
             logger.debug("Starting SSE writer")