(writer io.Writer)
| 19 | } |
| 20 | |
| 21 | func newZSTDWriter(writer io.Writer) (Writer, error) { |
| 22 | var level = 1 |
| 23 | var zstdLevel = zstd.SpeedFastest |
| 24 | |
| 25 | zstdWriter, err := zstd.NewWriter(writer, zstd.WithEncoderLevel(zstdLevel), zstd.WithWindowSize(16<<10), zstd.WithLowerEncoderMem(true)) |
| 26 | if err != nil { |
| 27 | return nil, err |
| 28 | } |
| 29 | |
| 30 | return &ZSTDWriter{ |
| 31 | writer: zstdWriter, |
| 32 | level: level, |
| 33 | }, nil |
| 34 | } |
| 35 | |
| 36 | func (this *ZSTDWriter) Write(p []byte) (int, error) { |
| 37 | return this.writer.Write(p) |