(db)
| 1360 | where_func = delay(timeout_sec + 1) |
| 1361 | |
| 1362 | async def get_x(db): |
| 1363 | doc = await anext(db.test.find().where(where_func)) |
| 1364 | return doc["x"] |
| 1365 | |
| 1366 | self.assertEqual(1, await get_x(no_timeout.pymongo_test)) |
| 1367 | with self.assertRaises(NetworkTimeout): |