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