()
| 62 | } |
| 63 | |
| 64 | func (z *zstdWriteCloser) Close() error { |
| 65 | compressed := z.enc.EncodeAll(z.buf.Bytes(), nil) |
| 66 | _, err := io.Copy(z.writer, bytes.NewReader(compressed)) |
| 67 | return err |
| 68 | } |
| 69 | |
| 70 | func (c *compressor) Decompress(r io.Reader) (io.Reader, error) { |
| 71 | compressed, err := io.ReadAll(r) |