(self)
| 501 | return f'<{res[1:-1]} [{extra}]>' |
| 502 | |
| 503 | async def __aenter__(self): |
| 504 | # wait for the barrier reaches the parties number |
| 505 | # when start draining release and return index of waited task |
| 506 | return await self.wait() |
| 507 | |
| 508 | async def __aexit__(self, *args): |
| 509 | pass |