docs: def _compress(self, cmd):
          """Adds the appropriate command to compress the zfs stream"""
          compressor = COMPRESSORS.get(self.compressor)
          if compressor is None:
              return cmd
          compress_cmd = compressor['compress']
          return "{} | {}".format(compress_cmd, cmd)