Wait for all tasks in the pool to complete
(self)
| 214 | return task |
| 215 | |
| 216 | async def wait_all(self) -> None: |
| 217 | """Wait for all tasks in the pool to complete""" |
| 218 | if self.tasks: |
| 219 | await asyncio.gather(*self.tasks) |
| 220 | |
| 221 | async def cancel_all(self) -> None: |
| 222 | """Cancel all tasks in the pool""" |
nothing calls this directly
no outgoing calls
no test coverage detected