utils.py 文件源码

def __call__(self, instance=None):
        if instance is not None and instance is not self._instance:
            fmt = "Instance mismatch on autoconsumer {}, ({} vs {})."
            msg = fmt.format(
                self._function.__name__,
                instance, self._instance,
            )
            logger.critical(msg)

        if self._generator is None:
            return

        try:
            endtime = time.monotonic() + self._timeout
            while time.monotonic() < endtime:
                next(self._generator)

        except StopIteration:
            self._generator = None

        else:
            QtCore.QMetaObject.invokeMethod(
                self._instance, self._function.__name__,
                Qt.Qt.QueuedConnection,
            )