(self)
Coroutine to run in background consuming incoming calls from child threads

        Launched in Bus.open()
Coroutine to run in background consuming incoming calls from child threads
Coroutine to run in background consuming incoming calls from child threads
async def _perform_calls(self):
        """Coroutine to run in background consuming incoming calls from child threads

        Launched in Bus.open()
        """
        while True:
            # Wait for calls
            logger.debug("Awaiting calls on the call queue")
            fn, args, kwargs, result_queue = await self._call_queue.async_q.get()

            # Execute call
            logger.debug("Call received, executing")
            result = await fn(*args, **kwargs)

            # Acknowledge the completion
            logger.debug("Call executed, marking as done")
            self._call_queue.async_q.task_done()

            # Put the result in the result queue
            logger.debug("Returning result")
            await result_queue.async_q.put(result)
async def _perform_calls ( self ) : while True : # Wait for calls logger . debug ( "Awaiting calls on the call queue" ) fn , args , kwargs , result_queue = await self . _call_queue . async_q . get ( ) # Execute call logger . debug ( "Call received, executing" ) result = await fn ( * args , * * kwargs ) # Acknowledge the completion logger . debug ( "Call executed, marking as done" ) self . _call_queue . async_q . task_done ( ) # Put the result in the result queue logger . debug ( "Returning result" ) await result_queue . async_q . put ( result )