(self)
| 587 | return await self._wait_for_one() |
| 588 | |
| 589 | def __next__(self): |
| 590 | if not self._todo_left: |
| 591 | raise StopIteration |
| 592 | assert self._todo_left > 0 |
| 593 | self._todo_left -= 1 |
| 594 | return self._wait_for_one(resolve=True) |
| 595 | |
| 596 | def _handle_timeout(self): |
| 597 | for f in self._todo: |
nothing calls this directly
no test coverage detected