fix: opendal Writer not closed (#1)

Signed-off-by: Xuanwo <github@xuanwo.io>
talzion12 · Apr 23, 2023 · 17d3ddb · 17d3ddb
1 parent bc16543
commit 17d3ddb
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -33,4 +33,4 @@ hex = "0.4.3"
 serde = { version = "1.0.160", features = ["derive"] }
 serde_json = "1.0.96"
 phf = { version = "0.11", features = ["macros"] }
-opendal = "0.32.0"
+opendal = "0.33.0"
diff --git a/src/cache/storage/opendal.rs b/src/cache/storage/opendal.rs
@@ -56,9 +56,11 @@ impl Cache for OpendalStorage {
         write_metadata_prefix(&mut writer, &metadata).await?;
 
         while let Some(part) = value.next().await {
-            writer.append(part).await?;
+            writer.write(part).await?;
         }
 
+        writer.close().await?;
+
         Ok(())
     }
 }