()
| 512 | |
| 513 | @asyncio.coroutine |
| 514 | def f(): |
| 515 | nonlocal acquired |
| 516 | connection2 = yield from conn.connect(Req()) |
| 517 | acquired = True |
| 518 | self.assertEqual(1, len(conn._acquired[key])) |
| 519 | connection2.release() |
| 520 | |
| 521 | task = asyncio.async(f(), loop=self.loop) |
| 522 |