(self, apis: List[Api] = None)
Start a background task to consume RPCs

        This will consumer RPCs on APIs which have been registered with this
        bus client.
Start a background task to consume RPCs
Start a background task to consume RPCs
async def consume_rpcs(self, apis: List[Api] = None):
        """Start a background task to consume RPCs

        This will consumer RPCs on APIs which have been registered with this
        bus client.
        """
        if apis is None:
            apis = self.api_registry.all()

        if not apis:
            raise NoApisToListenOn(
                "No APIs to consume on in consume_rpcs(). Either this method was called with apis=[], "
                "or the API registry is empty."
            )

        api_names = [api.meta.name for api in apis]

        await self.producer.send(ConsumeRpcsCommand(api_names=api_names)).wait()
async def consume_rpcs ( self , apis : List [ Api ] = None ) : if apis is None : apis = self . api_registry . all ( ) if not apis : raise NoApisToListenOn ( "No APIs to consume on in consume_rpcs(). Either this method was called with apis=[], " "or the API registry is empty." ) api_names = [ api . meta . name for api in apis ] await self . producer . send ( ConsumeRpcsCommand ( api_names = api_names ) ) . wait ( )