Bump opendal to 0.45

CHANGELOG.md

@@ -9,6 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
  - Bump `crc32` to 0.6.5 to fix nightly build
+ - Bump `opendal` to `0.45`
 
 ## [0.11.6] - 2024-02-06
 

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "zarrs"
-version = "0.11.6"
+version = "0.11.7"
 authors = ["Lachlan Deakin <[email protected]>"]
 edition = "2021"
 rust-version = "1.71"
@@ -57,7 +57,7 @@ itertools = "0.12"
 ndarray = { version = "0.15", optional = true }
 num = { version = "0.4" }
 object_store = { version = "0.9.0", optional = true }
-opendal = { version = "0.44", optional = true }
+opendal = { version = "0.45", optional = true }
 parking_lot = "0.12"
 pathdiff = "0.2"
 pco = { version = "0.1.3", optional = true }

src/storage/store/store_async/opendal.rs

@@ -1,4 +1,4 @@
-use std::sync::Arc;
+use std::{future::IntoFuture, sync::Arc};
 
 use opendal::Operator;
 
@@ -74,6 +74,7 @@ impl AsyncReadableStorageTraits for AsyncOpendalStore {
                     self.operator
                         .read_with(key.as_str())
                         .range(byte_range.offset()..)
+                        .into_future()
                 })
                 .collect::<Vec<_>>();
             handle_result(futures::future::try_join_all(futures).await)
@@ -90,6 +91,7 @@ impl AsyncReadableStorageTraits for AsyncOpendalStore {
                     self.operator
                         .read_with(key.as_str())
                         .range(start..end)
+                        .into_future()
                         .map(move |bytes| match bytes {
                             Ok(bytes) => {
                                 if (end - start) == bytes.len() as u64 {