docs: def decompress_messages(self, offmsgs):
          """ Decompress pre-defined compressed fields for each message.
              Msgs should be unpacked before this step. """
  
          for offmsg in offmsgs:
              yield offmsg.message.key, self.decompress_fun(offmsg.message.value)