Used by wait(return_when=FIRST_COMPLETED).
| 94 | self.event.set() |
| 95 | |
| 96 | class _FirstCompletedWaiter(_Waiter): |
| 97 | """Used by wait(return_when=FIRST_COMPLETED).""" |
| 98 | |
| 99 | def add_result(self, future): |
| 100 | super().add_result(future) |
| 101 | self.event.set() |
| 102 | |
| 103 | def add_exception(self, future): |
| 104 | super().add_exception(future) |
| 105 | self.event.set() |
| 106 | |
| 107 | def add_cancelled(self, future): |
| 108 | super().add_cancelled(future) |
| 109 | self.event.set() |
| 110 | |
| 111 | class _AllCompletedWaiter(_Waiter): |
| 112 | """Used by wait(return_when=FIRST_EXCEPTION and ALL_COMPLETED).""" |
no outgoing calls
no test coverage detected