Shutdown instead of flush

neondatabase · Jun 14, 2024 · a82196d · a82196d
1 parent 9da0772
commit a82196d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pageserver/src/tenant/blob_io.rs b/pageserver/src/tenant/blob_io.rs
@@ -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;