(
session: Optional[AsyncClientSession],
_server: Server,
conn: AsyncConnection,
read_preference: Optional[_ServerMode],
)
| 2062 | kwargs["comment"] = comment |
| 2063 | |
| 2064 | async def _cmd( |
| 2065 | session: Optional[AsyncClientSession], |
| 2066 | _server: Server, |
| 2067 | conn: AsyncConnection, |
| 2068 | read_preference: Optional[_ServerMode], |
| 2069 | ) -> int: |
| 2070 | cmd: dict[str, Any] = {"count": self._name} |
| 2071 | cmd.update(kwargs) |
| 2072 | return await self._count_cmd(session, conn, read_preference, cmd, collation=None) |
| 2073 | |
| 2074 | return await self._retryable_non_cursor_read(_cmd, None, operation=_Op.COUNT) |
| 2075 |
nothing calls this directly
no test coverage detected