async def METHOD_NAME(self, message_type):
    # On application exit, we first await completion of all tasks in the queue.
    if self._conn_future is not None:
        await asyncio.wait([self._conn_future], return_when=asyncio.ALL_COMPLETED)