diff --git a/src/mcp/server/sse.py b/src/mcp/server/sse.py
index 192c1290b..781c890ee 100644
--- a/src/mcp/server/sse.py
+++ b/src/mcp/server/sse.py
@@ -156,6 +156,7 @@ async def response_wrapper(scope: Scope, receive: Receive, send: Send):
                 )(scope, receive, send)
                 await read_stream_writer.aclose()
                 await write_stream_reader.aclose()
+                self._read_stream_writers.pop(session_id, None)
                 logging.debug(f"Client session disconnected {session_id}")
 
             logger.debug("Starting SSE response task")