(w io.Writer)
| 46 | } |
| 47 | |
| 48 | func (wc *wrapCompressor) Compress(w io.Writer) (io.WriteCloser, error) { |
| 49 | atomic.AddInt32(&wc.compressInvokes, 1) |
| 50 | return wc.Compressor.Compress(w) |
| 51 | } |
| 52 | |
| 53 | func setupGzipWrapCompressor(t *testing.T) *wrapCompressor { |
| 54 | regFn := internal.RegisterCompressorForTesting.(func(encoding.Compressor) func()) |