Use correct close_conn

Author: NoahStapp

Diff for: pymongo/asynchronous/pool.py

@@ -863,7 +863,7 @@ async def _reset(
         if close:
             if not _IS_SYNC:
                 await asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.POOL_CLOSED) for conn in sockets]
+                    *[conn.close_conn(ConnectionClosedReason.POOL_CLOSED) for conn in sockets]
                 )
             else:
                 for conn in sockets:
@@ -899,7 +899,7 @@ async def _reset(
                     )
             if not _IS_SYNC:
                 await asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.STALE) for conn in sockets]
+                    *[conn.close_conn(ConnectionClosedReason.STALE) for conn in sockets]
                 )
             else:
                 for conn in sockets:
@@ -951,7 +951,7 @@ async def remove_stale_sockets(self, reference_generation: int) -> None:
                     close_conns.append(self.conns.pop())
             if not _IS_SYNC:
                 await asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.IDLE) for conn in close_conns]
+                    *[conn.close_conn(ConnectionClosedReason.IDLE) for conn in close_conns]
                 )
             else:
                 for conn in close_conns:

Diff for: pymongo/synchronous/pool.py

@@ -861,7 +861,7 @@ def _reset(
         if close:
             if not _IS_SYNC:
                 asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.POOL_CLOSED) for conn in sockets]
+                    *[conn.close_conn(ConnectionClosedReason.POOL_CLOSED) for conn in sockets]
                 )
             else:
                 for conn in sockets:
@@ -896,9 +896,7 @@ def _reset(
                         serviceId=service_id,
                     )
             if not _IS_SYNC:
-                asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.STALE) for conn in sockets]
-                )
+                asyncio.gather(*[conn.close_conn(ConnectionClosedReason.STALE) for conn in sockets])
             else:
                 for conn in sockets:
                     conn.close_conn(ConnectionClosedReason.STALE)
@@ -947,7 +945,7 @@ def remove_stale_sockets(self, reference_generation: int) -> None:
                     close_conns.append(self.conns.pop())
             if not _IS_SYNC:
                 asyncio.gather(
-                    *[conn._close_conn(ConnectionClosedReason.IDLE) for conn in close_conns]
+                    *[conn.close_conn(ConnectionClosedReason.IDLE) for conn in close_conns]
                 )
             else:
                 for conn in close_conns: