code: 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
docs: Blocks until new message appear.