Establish the connection asynchronously.
(self)
| 51 | |
| 52 | @retry |
| 53 | async def connect(self) -> bool: |
| 54 | """Establish the connection asynchronously.""" |
| 55 | log(f"Connecting to {self._name}:{self.__port}") |
| 56 | self._connected = True |
| 57 | return True |
| 58 | |
| 59 | def disconnect(self) -> None: |
| 60 | self._connected = False |