Method Decompress

pkg/util/grpcencoding/snappy/snappy.go:55–59

(r io.Reader)

}

func (c *compressor) Decompress(r io.Reader) (io.Reader, error) {
	dr := c.readersPool.Get().(*snappy.Reader)
	dr.Reset(r)
	return reader{dr, &c.readersPool}, nil
}

type writeCloser struct {
	writer *snappy.Writer