(self)
| 225 | self._exhaust_checked = False |
| 226 | |
| 227 | async def _supports_exhaust(self) -> None: |
| 228 | # Exhaust cursor support |
| 229 | if self._cursor_type == CursorType.EXHAUST: |
| 230 | if await self._collection.database.client.is_mongos: |
| 231 | raise InvalidOperation("Exhaust cursors are not supported by mongos") |
| 232 | if self._limit: |
| 233 | raise InvalidOperation("Can't use limit and exhaust together.") |
| 234 | self._exhaust = True |
| 235 | |
| 236 | @property |
| 237 | def collection(self) -> AsyncCollection[_DocumentType]: |
no test coverage detected