Don't forget the flush

This commit is contained in:
Arpad Müller
2024-06-14 05:26:51 +02:00
parent 07bd0ce69e
commit 2f70221503

View File

@@ -114,6 +114,7 @@ impl<'a> BlockCursor<'a> {
if compression_bits == BYTE_ZSTD {
let mut decoder = async_compression::tokio::write::ZstdDecoder::new(dstbuf);
decoder.write_all(buf_to_write).await?;
decoder.flush().await?;
} else if compression_bits == BYTE_LZ4 {
let decompressed = lz4_flex::block::decompress(&buf_to_write, 128 as usize)
.map_err(|_| {