(self, address)
| 40 | return s + ")>" |
| 41 | |
| 42 | async def connect_to(self, address): |
| 43 | self.host, self.port = address |
| 44 | await self.connect_check_health( |
| 45 | check_health=self.connection_pool.check_connection, |
| 46 | retry_socket_connect=False, |
| 47 | ) |
| 48 | |
| 49 | async def _connect_retry(self): |
| 50 | if self._reader: |
no test coverage detected