(self)
| 154 | |
| 155 | @async_client_context.require_connection |
| 156 | async def asyncSetUp(self): |
| 157 | await super().asyncSetUp() |
| 158 | self.c = await self.async_rs_or_single_client() |
| 159 | db = self.c[DB] |
| 160 | await db.unique.drop() |
| 161 | await db.test.drop() |
| 162 | await db.unique.insert_one({"_id": "jesse"}) |
| 163 | await db.test.insert_many([{} for _ in range(10)]) |
| 164 | |
| 165 | async def create_pool(self, pair=None, *args, **kwargs): |
| 166 | if pair is None: |
nothing calls this directly
no test coverage detected