(self)
| 65 | self.name = f'Timer-{next(self._timer_count)}' |
| 66 | |
| 67 | def _next_entry(self) -> Optional[float]: |
| 68 | with self.not_empty: |
| 69 | delay: Optional[float] |
| 70 | entry: Optional[Entry] |
| 71 | delay, entry = next(self.scheduler) |
| 72 | if entry is None: |
| 73 | if delay is None: |
| 74 | self.not_empty.wait(1.0) |
| 75 | return delay |
| 76 | return self.schedule.apply_entry(entry) |
| 77 | __next__ = next = _next_entry # for 2to3 |
| 78 | |
| 79 | def run(self) -> None: |
no test coverage detected