code: def is_active(self):
          
          if self._queue.exhausted:
              return False
          return any(ch.is_active for ch in self._refs.values())
docs: Returns True if listener has any active subscription.