Explicitly close _list_collection_names cursor

Author: NoahStapp

pymongo/asynchronous/database.py

@@ -621,6 +621,8 @@ async def create_collection(
                 and name in await self._list_collection_names(filter={"name": name}, session=s)
             ):
                 raise CollectionInvalid("collection %s already exists" % name)
+            if s:
+                s._leave_alive = False
             coll = AsyncCollection(
                 self,
                 name,
@@ -1206,10 +1208,12 @@ async def _list_collection_names(
             if not filter or (len(filter) == 1 and "name" in filter):
                 kwargs["nameOnly"] = True
 
-        return [
-            result["name"]
-            async for result in await self._list_collections_helper(session=session, **kwargs)
-        ]
+        cursor = await self._list_collections_helper(session=session, **kwargs)
+        results = [result["name"] async for result in cursor]
+
+        await cursor.close()
+
+        return results
 
     async def list_collection_names(
         self,

pymongo/synchronous/database.py

@@ -621,6 +621,8 @@ def create_collection(
                 and name in self._list_collection_names(filter={"name": name}, session=s)
             ):
                 raise CollectionInvalid("collection %s already exists" % name)
+            if s:
+                s._leave_alive = False
             coll = Collection(
                 self,
                 name,
@@ -1200,9 +1202,12 @@ def _list_collection_names(
             if not filter or (len(filter) == 1 and "name" in filter):
                 kwargs["nameOnly"] = True
 
-        return [
-            result["name"] for result in self._list_collections_helper(session=session, **kwargs)
-        ]
+        cursor = self._list_collections_helper(session=session, **kwargs)
+        results = [result["name"] for result in cursor]
+
+        cursor.close()
+
+        return results
 
     def list_collection_names(
         self,