| 112 | } |
| 113 | |
| 114 | void CheckCompressedInputStream(Codec* codec, const std::vector<uint8_t>& data) { |
| 115 | // Create compressed data |
| 116 | auto compressed = CompressDataOneShot(codec, data); |
| 117 | |
| 118 | std::vector<uint8_t> decompressed; |
| 119 | int64_t stream_pos = -1; |
| 120 | ASSERT_OK(RunCompressedInputStream(codec, compressed, &stream_pos, &decompressed)); |
| 121 | |
| 122 | ASSERT_EQ(decompressed.size(), data.size()); |
| 123 | ASSERT_EQ(decompressed, data); |
| 124 | ASSERT_EQ(stream_pos, static_cast<int64_t>(decompressed.size())); |
| 125 | } |
| 126 | |
| 127 | void CheckCompressedOutputStream(Codec* codec, const std::vector<uint8_t>& data, |
| 128 | bool do_flush) { |
no test coverage detected