rdisq/request/dispatcher.py
def find_queues_for_services(self, service_uids: Set[str]) -> FrozenSet[QueueName]:
        """
        Find all queues that are listened to by all these services.

        :param service_uids: Set IDs of queues to match.
        :return: Set of queue names.
        """
        services = self.get_receiver_services().values()
        queue_to_services: Dict[QueueName, set] = defaultdict(set)
        for service in services:
            for q in service.broadcast_queues:
                queue_to_services[q].add(service.uid)

        queue_to_services = {k: v for k, v in queue_to_services.items() if
                             v == service_uids}

        return frozenset(queue_to_services.keys())

        Find all queues that are listened to by all these services.

        :param service_uids: Set IDs of queues to match.
        :return: Set of queue names.
        
Find all queues that are listened to by all these services.
Find all queues that are listened to by all these services .
def find_queues_for_services(self, service_uids: Set[str]) -> FrozenSet[QueueName]:
        services = self.get_receiver_services().values()
        queue_to_services: Dict[QueueName, set] = defaultdict(set)
        for service in services:
            for q in service.broadcast_queues:
                queue_to_services[q].add(service.uid)
        queue_to_services = {k: v for k, v in queue_to_services.items() if
                             v == service_uids}
        return frozenset(queue_to_services.keys())
def find_queues_for_services ( self , service_uids : Set [ str ] ) -> FrozenSet [ QueueName ] : services = self . get_receiver_services ( ) . values ( ) queue_to_services : Dict [ QueueName , set ] = defaultdict ( set ) for service in services : for q in service . broadcast_queues : queue_to_services [ q ] . add ( service . uid ) queue_to_services = { k : v for k , v in queue_to_services . items ( ) if v == service_uids } return frozenset ( queue_to_services . keys ( ) )
Find all queues that are listened to by all these services.
Find all queues that are listened to by all these services .
"""
        Find all queues that are listened to by all these services.

        :param service_uids: Set IDs of queues to match.
        :return: Set of queue names.
        """
Set of queue names.
Set of queue names .
self
service_uids
Set[str]
Set IDs of queues to match.
Set IDs of queues to match .