Shutdown instead of flush

This commit is contained in:
Arpad Müller
2024-06-18 17:50:47 +02:00
parent 2f70221503
commit 2ea8d1b151
+1 -1
View File
@@ -322,7 +322,7 @@ impl<const BUFFERED: bool> BlobWriter<BUFFERED> {
};
let slice = srcbuf.slice(..);
encoder.write_all(&slice[..]).await.unwrap();
encoder.flush().await.unwrap();
encoder.shutdown().await.unwrap();
let compressed = encoder.into_inner();
if compressed.len() < len {
let compressed_len = len;