(pool)
| 499 | return res + 1 |
| 500 | |
| 501 | async def test(pool): |
| 502 | async with pool.acquire() as con: |
| 503 | self.assertEqual(await con.fetchval('SELECT 1'), 2) |
| 504 | self.assertEqual(await con.foo(), 42) |
| 505 | self.assertTrue(isinstance(con, MyConnection)) |
| 506 | self.assertEqual(con._con._config.statement_cache_size, 3) |
| 507 | cons.add(con) |
| 508 | |
| 509 | async with self.create_pool( |
| 510 | database='postgres', min_size=10, max_size=10, |