(
        self, listen_for: List[Tuple[str, str]], listener_name: str, **kwargs
    )
Consume RPC events for the given API
Consume RPC events for the given API
Consume RPC events for the given API
async def consume(
        self, listen_for: List[Tuple[str, str]], listener_name: str, **kwargs
    ) -> AsyncGenerator[EventMessage, None]:
        """Consume RPC events for the given API"""
        self._sanity_check_listen_for(listen_for)

        logger.info("⌛ Faking listening for events {}.".format(self._events))

        while True:
            await asyncio.sleep(0.1)
            yield [self._get_fake_message()]
async def consume ( self , listen_for : List [ Tuple [ str , str ] ] , listener_name : str , * * kwargs ) -> AsyncGenerator [ EventMessage , None ] : self . _sanity_check_listen_for ( listen_for ) logger . info ( "⌛ Faking listening for events {}.".f o rmat(s e lf._ e vents)) while True : await asyncio . sleep ( 0.1 ) yield [ self . _get_fake_message ( ) ]