(self)
| 560 | self.assertTrue(t.result()) |
| 561 | |
| 562 | async def test_wait_for_unacquired(self): |
| 563 | cond = asyncio.Condition() |
| 564 | |
| 565 | # predicate can return true immediately |
| 566 | res = await cond.wait_for(lambda: [1, 2, 3]) |
| 567 | self.assertEqual([1, 2, 3], res) |
| 568 | |
| 569 | with self.assertRaises(RuntimeError): |
| 570 | await cond.wait_for(lambda: False) |
| 571 | |
| 572 | async def test_notify(self): |
| 573 | cond = asyncio.Condition() |
nothing calls this directly
no test coverage detected