(buf []byte)
| 32 | } |
| 33 | |
| 34 | func (c *ZstdCodec) Decode(buf []byte) ([]byte, error) { |
| 35 | d, _ := c.decoders.Get().(*zstd.Decoder) |
| 36 | if d == nil { |
| 37 | var err error |
| 38 | d, err = zstd.NewReader(nil, zstd.WithDecoderConcurrency(0)) |
| 39 | if err != nil { |
| 40 | return nil, err |
| 41 | } |
| 42 | } |
| 43 | defer c.decoders.Put(d) |
| 44 | return d.DecodeAll(buf, nil) |
| 45 | } |