(self)
| 1711 | self.assertEqual(barrier.n_waiting, 0) |
| 1712 | |
| 1713 | async def test_abort_barrier(self): |
| 1714 | barrier = asyncio.Barrier(1) |
| 1715 | |
| 1716 | asyncio.create_task(barrier.abort()) |
| 1717 | await asyncio.sleep(0) |
| 1718 | |
| 1719 | self.assertEqual(barrier.n_waiting, 0) |
| 1720 | self.assertTrue(barrier.broken) |
| 1721 | |
| 1722 | async def test_abort_barrier_when_tasks_half_draining_half_blocking(self): |
| 1723 | barrier = asyncio.Barrier(self.N) |
nothing calls this directly
no test coverage detected