(self)
| 471 | return f'<{res[1:-1]} [{extra}]>' |
| 472 | |
| 473 | async def __aenter__(self): |
| 474 | # wait for the barrier reaches the parties number |
| 475 | # when start draining release and return index of waited task |
| 476 | return await self.wait() |
| 477 | |
| 478 | async def __aexit__(self, *args): |
| 479 | pass |