()
| 608 | timeout_handle.cancel() |
| 609 | |
| 610 | async def _wait_for_one(): |
| 611 | f = await done.get() |
| 612 | if f is None: |
| 613 | # Dummy value from _on_timeout(). |
| 614 | raise exceptions.TimeoutError |
| 615 | return f.result() # May raise f.exception(). |
| 616 | |
| 617 | for f in todo: |
| 618 | f.add_done_callback(_on_completion) |
no test coverage detected