Method Read

pkg/util/grpcencoding/snappyblock/snappyblock.go:135–143

(p []byte)

}

func (r *reader) Read(p []byte) (n int, err error) {
	n, err = r.dbuff.Read(p)
	if err == io.EOF {
		r.cbuff.Reset()
		r.dst = r.dst[0:cap(r.dst)]
		r.pool.Put(r)
	}
	return n, err
}