(p []byte)
| 123 | } |
| 124 | |
| 125 | func (er *DelayedErrorReader) Read(p []byte) (int, error) { |
| 126 | x, err := er.underlying.Read(p) |
| 127 | if err != nil { |
| 128 | return 0, err |
| 129 | } |
| 130 | er.n -= x |
| 131 | if er.n < 0 { |
| 132 | return 0, errors.New("mock reader: read error") |
| 133 | } else { |
| 134 | return x, nil |
| 135 | } |
| 136 | } |
| 137 | |
| 138 | func testCompressAndEncryptErrorPropagation(compressor compression.Compressor, t *testing.T) { |
| 139 | L := 1 << 20 |