(self)
| 168 | ) |
| 169 | |
| 170 | def on_timeout(self) -> None: |
| 171 | self.timeout = None |
| 172 | if not self.future.done(): |
| 173 | self.try_connect(iter(self.secondary_addrs)) |
| 174 | |
| 175 | def clear_timeout(self) -> None: |
| 176 | if self.timeout is not None: |
no test coverage detected