test

Author: felixweinberger

src/mcp/client/stdio/win32.py

@@ -80,16 +80,32 @@ async def __aexit__(
         await to_thread.run_sync(self.popen.wait)
 
         # Close the file handles to prevent ResourceWarning
+        # Handle already-closed streams gracefully
         if self.stdin:
-            await self.stdin.aclose()
+            try:
+                await self.stdin.aclose()
+            except Exception:
+                pass  # Already closed
         if self.stdout:
-            await self.stdout.aclose()
+            try:
+                await self.stdout.aclose()
+            except Exception:
+                pass  # Already closed
         if self.stdin_raw:
-            self.stdin_raw.close()
+            try:
+                self.stdin_raw.close()
+            except Exception:
+                pass  # Already closed
         if self.stdout_raw:
-            self.stdout_raw.close()
+            try:
+                self.stdout_raw.close()
+            except Exception:
+                pass  # Already closed
         if self.stderr:
-            self.stderr.close()
+            try:
+                self.stderr.close()
+            except Exception:
+                pass  # Already closed
 
     async def wait(self):
         """Async wait for process completion."""