(self)
| 661 | await self._test_ops(client, (agg, [], {})) |
| 662 | |
| 663 | async def test_killcursors(self): |
| 664 | client = self.client |
| 665 | coll = client.pymongo_test.collection |
| 666 | await coll.insert_many([{} for _ in range(10)]) |
| 667 | |
| 668 | async def explicit_close(session=None): |
| 669 | cursor = coll.find(batch_size=2, session=session) |
| 670 | await anext(cursor) |
| 671 | await cursor.close() |
| 672 | |
| 673 | await self._test_ops(client, (explicit_close, [], {})) |
| 674 | |
| 675 | async def test_aggregate_error(self): |
| 676 | listener = self.listener |
nothing calls this directly
no test coverage detected