code: async def reconnect(self):
          
          monitor = self.monitor
          if monitor.reconnecting.locked() or monitor.close_called.is_set():
              return
          async with monitor.reconnecting:
              await self.close()
              await self._connect_with_login([(self.endpoint, self.cacert)])
docs: Force a reconnection.