code: async def parse_response(self, block=True, timeout=0):
          "Parse the response from a publish/subscribe command"
          connection = self.connection
          if connection is None:
              raise RuntimeError(
                  'pubsub connection not set: '
                  'did you forget to call subscribe() or psubscribe()?')
          coro = self._execute(connection, connection.read_response)
          if not block and timeout > 0:
              try:
                  return await asyncio.wait_for(coro, timeout)
              except Exception:
                  return None
          return await corync def parse_response(self, block=True, timeout=0):
          "Parse the response from a publish/subscribe command"
          connection = self.connection
          if connection is None:
              raise RuntimeError(
                  'pubsub connection not set: '
                  'did you forget to call subscribe() or psubscribe()?')
          coro = self._execute(connection, connection.read_response)
          if not block and timeout > 0:
              try:
                  return await asyncio.wait_for(coro, timeout)
              except Exception:
                  return None
          return await coro
docs: Parse the response from a publish/subscribe command