Function WithConcurrentBlocks

zstd/encoder_options.go:345–353

WithConcurrentBlocks enables job-based parallel compression for streams. When enabled and concurrent > 1, input is split into large sections (jobs) that are compressed simultaneously by multiple goroutines. Each non-first job receives an overlap prefix from the previous job for match context. Output

(b bool)

// Currently disabled when used with dictionary encoding.
// Cannot be changed with ResetWithOptions.
func WithConcurrentBlocks(b bool) EOption {
	return func(o *encoderOptions) error {
		if o.resetOpt && b != o.concurrentBlocks {
			return errors.New("WithConcurrentBlocks cannot be changed on Reset")
		}
		o.concurrentBlocks = b
		return nil
	}
}

// jobSize returns the input section size per parallel job.
func (o *encoderOptions) jobSize() int {