device.py 文件源码

def loop(self, timeout=1):
        """ Performs network activity when connected in non blocking mode """
        if self._looping:
            raise Exception("Connection in blocking mode, don't call loop")

        if self._mqtt_client:
            result = self._mqtt_client.loop(timeout)
            if result != mqtt.MQTT_ERR_SUCCESS:
                LOGGER.debug("Attempting another reconnect for %s...", self._device_id)
                self._wrapped_reconnect()