(self)
Async version of close()
Async version of close()
Async version of close ()
async def close_async(self):
        """Async version of close()"""
        if self._closed:
            raise BusAlreadyClosed()

        await cancel_and_log_exceptions(*self._background_tasks)

        await self.event_client.close()
        await self.rpc_result_client.close()
        await self.schema.close()

        while not self.error_queue.empty():
            logger.error(self.error_queue.get_nowait())

        self._closed = True
async def close_async ( self ) : if self . _closed : raise BusAlreadyClosed ( ) await cancel_and_log_exceptions ( * self . _background_tasks ) await self . event_client . close ( ) await self . rpc_result_client . close ( ) await self . schema . close ( ) while not self . error_queue . empty ( ) : logger . error ( self . error_queue . get_nowait ( ) ) self . _closed = True