code: async def handle_disconnect_callback(self):
          
          self.is_connected = False
          if self.disconnect_callback:
              self.disconnect_callback()
          if self.reconnect:
              self.logger.debug("Protocol disconnected...reconnecting")
              await self.setup()
              self.protocol.reset_cmd_timeout()
              if self.in_transaction:
                  self.protocol.transport.write(self.active_packet)
              else:
                  packet = self.protocol.format_packet(b"\x1e")
                  self.protocol.transport.write(packet)
docs: Reconnect automatically unless stopping.