Function newZstdCompressor

repo/compression/compressor_zstd.go:21–30

(id HeaderID, level zstd.EncoderLevel)

}

func newZstdCompressor(id HeaderID, level zstd.EncoderLevel) Compressor {
	return &zstdCompressor{id, compressionHeader(id), sync.Pool{
		New: func() any {
			w, err := zstd.NewWriter(io.Discard, zstd.WithEncoderLevel(level))
			mustSucceed(err)

			return w
		},
	}}
}

type zstdCompressor struct {
	id     HeaderID