def can_consume(self):
        """Return true if the channel can be consumed from.

        Used to ensure the client adhers to currently active
        prefetch limits.

        """
        pcount = self.prefetch_count
        return not pcount or pcount < len(self._delivered) - len(self._dirty)
dataset/ETHPy150Open celery/kombu/kombu/transport/virtual/__init__.py/QoS.can_consume/swapped operands of `<`