docs: async def connect(self, connection):
          """
          Connects to the specified given connection using the given auth key.
          """
          if self._user_connected:
              self._log.info('User is already connected!')
              return
  
          self._connection = connection
          await self._connect()
          self._user_connected = True