(
        self, listen_for: List[Tuple[str, str]], listener_name: str, **kwargs
    )
Consume messages for the given APIs

        Examples:

            Consuming events::

                listen_for = [
                    ('mycompany.auth', 'user_created'),
                    ('mycompany.auth', 'user_updated'),
                ]
                async with event_transport.consume(listen_for) as event_message:
                    print(event_message)
Consume messages for the given APIs
Consume messages for the given APIs
async def consume(
        self, listen_for: List[Tuple[str, str]], listener_name: str, **kwargs
    ) -> AsyncGenerator[List[EventMessage], None]:
        """Consume messages for the given APIs

        Examples:

            Consuming events::

                listen_for = [
                    ('mycompany.auth', 'user_created'),
                    ('mycompany.auth', 'user_updated'),
                ]
                async with event_transport.consume(listen_for) as event_message:
                    print(event_message)

        """
        raise NotImplementedError(
            f"Event transport {self.__class__.__name__} does not support listening for events"
        )
async def consume ( self , listen_for : List [ Tuple [ str , str ] ] , listener_name : str , * * kwargs ) -> AsyncGenerator [ List [ EventMessage ] , None ] : raise NotImplementedError ( f"Event transport {self.__class__.__name__} does not support listening for events" )