(self)
| 164 | ) |
| 165 | |
| 166 | def on_timeout(self) -> None: |
| 167 | self.timeout = None |
| 168 | if not self.future.done(): |
| 169 | self.try_connect(iter(self.secondary_addrs)) |
| 170 | |
| 171 | def clear_timeout(self) -> None: |
| 172 | if self.timeout is not None: |
no test coverage detected