()
| 159 | |
| 160 | |
| 161 | def test_cache_chunk_buffer(): |
| 162 | data = [Item(path="p1"), Item(path="p2")] |
| 163 | cache = MockCache() |
| 164 | key = PlaintextKey(None) |
| 165 | chunks = CacheChunkBuffer(cache, key, None) |
| 166 | for d in data: |
| 167 | chunks.add(d) |
| 168 | chunks.flush() |
| 169 | chunks.flush(flush=True) |
| 170 | assert len(chunks.chunks) == 2 |
| 171 | unpacker = msgpack.Unpacker() |
| 172 | for id in chunks.chunks: |
| 173 | unpacker.feed(cache.objects[id]) |
| 174 | assert data == [Item(internal_dict=d) for d in unpacker] |
| 175 | |
| 176 | |
| 177 | def test_partial_cache_chunk_buffer(): |
nothing calls this directly
no test coverage detected