code: async def get_message(self, ignore_subscribe_messages=False, timeout=0):
          
          response = await self.parse_response(block=False, timeout=timeout)
          if response:
              return self.handle_message(response, ignore_subscribe_messages)
          return None
docs: Get the next message if one is available, otherwise None.
  
          If timeout is specified, the system will wait for `timeout` seconds
          before returning. Timeout should be specified as a floating point
          number.