fix parasite changes

qoollo · Feb 3, 2023 · 8d488c8 · 8d488c8
1 parent 4fe5488
commit 8d488c8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/blob/core.rs b/src/blob/core.rs
@@ -283,7 +283,7 @@ where
         Ok(())
     }
 
-    pub(crate) async fn read_last(
+    pub(crate) async fn read_any(
         &self,
         key: &K,
         meta: Option<&Meta>,

diff --git a/src/storage/core.rs b/src/storage/core.rs
@@ -486,7 +486,7 @@ where
         debug!("storage read with optional meta {:?}, {:?}", key, meta);
         let safe = self.inner.safe.read().await;
         if let Some(ablob) = safe.active_blob.as_ref() {
-            match ablob.read().await.read_last(key, meta, true).await {
+            match ablob.read().await.read_any(key, meta, true).await {
                 Ok(data) => {
                     if data.is_presented() {
                         debug!("storage read with optional meta active blob returned data");
@@ -526,10 +526,10 @@ where
         let stream: FuturesOrdered<_> = possible_blobs
             .into_iter()
             .filter_map(|id| blobs.get_child(id))
-            .map(|blob| blob.data.read_last(key, meta, false))
+            .map(|blob| blob.data.read_any(key, meta, false))
             .collect();
         debug!("read with optional meta {} closed blobs", stream.len());
-        
+
         let mut task = stream.skip_while(|read_res| {
             match read_res {
                 Ok(inner_res) => inner_res.is_not_found(), // Skip not found