code: async def _connect(self):
          
          self.waiting = True
          await self.client.start(self.ip)
          self.waiting = False
          if self.client.protocol is None:
              raise IOError("Could not connect to '{}'.".format(self.ip))
          self.open = True
docs: Start asynchronous reconnect loop.