(t *testing.T)
| 95 | } |
| 96 | |
| 97 | func TestCompressAndEncryptBigChunk(t *testing.T) { |
| 98 | L := 1024 * 1024 // 1Mb |
| 99 | b := make([]byte, L) |
| 100 | rand.Read(b) |
| 101 | in := &testtools.BufCloser{Buffer: bytes.NewBuffer(b), Err: false} |
| 102 | |
| 103 | compressor := GetLz4Compressor() |
| 104 | compressed := internal.CompressAndEncrypt(in, compressor, nil) |
| 105 | |
| 106 | decompressor := compression.GetDecompressorByCompressor(compressor) |
| 107 | decompressed, err := decompressor.Decompress(compressed) |
| 108 | if err != nil { |
| 109 | t.Logf("%+v\n", err) |
| 110 | } |
| 111 | defer decompressed.Close() |
| 112 | out := &testtools.BufCloser{Buffer: &bytes.Buffer{}, Err: false} |
| 113 | _, err = io.Copy(out, decompressed) |
| 114 | assert.NoError(t, err) |
| 115 | |
| 116 | assert.Equalf(t, b, out.Bytes(), "Incorrect decompression") |
| 117 | |
| 118 | } |
| 119 | |
| 120 | type DelayedErrorReader struct { |
| 121 | underlying io.Reader |
nothing calls this directly
no test coverage detected