(self, f)
| 600 | self._todo.clear() # Can't do todo.remove(f) in the loop. |
| 601 | |
| 602 | def _handle_completion(self, f): |
| 603 | if not self._todo: |
| 604 | return # _handle_timeout() was here first. |
| 605 | self._todo.remove(f) |
| 606 | self._done.put_nowait(f) |
| 607 | if not self._todo and self._timeout_handle is not None: |
| 608 | self._timeout_handle.cancel() |
| 609 | |
| 610 | async def _wait_for_one(self, resolve=False): |
| 611 | # Wait for the next future to be done and return it unless resolve is |
nothing calls this directly
no test coverage detected