async def wait_message(self):
        """Blocks until new message appear."""
        if not self._queue.empty():
            return True
        if self._queue.closed:
            return False
        await self._queue.wait()
        return self.is_active
async def wait_message ( self ) : if not self . _queue . empty ( ) : return True if self . _queue . closed : return False await self . _queue . wait ( ) return self . is_active
Blocks until new message appear.