(reader io.Reader)
| 14 | } |
| 15 | |
| 16 | func NewZSTDReader(reader io.Reader) (Reader, error) { |
| 17 | return sharedZSTDReaderPool.Get(reader) |
| 18 | } |
| 19 | |
| 20 | func newZSTDReader(reader io.Reader) (Reader, error) { |
| 21 | r, err := zstd.NewReader(reader, zstd.WithDecoderMaxWindow(256<<20)) |