fmt

Author: MarinPostma

libsql-wal/src/replication/storage.rs

@@ -44,7 +44,6 @@ where
         mut current: u64,
         until: u64,
     ) -> Pin<Box<dyn Stream<Item = Result<Box<Frame>>> + Send + 'a>> {
-        
         Box::pin(async_stream::try_stream! {
             loop {
                 let key = self.storage.find_segment(&self.namespace, FindSegmentReq::EndFrameNoLessThan(current), None).await?;

libsql-wal/src/storage/async_storage.rs

@@ -232,14 +232,7 @@ where
         config_override: Option<Self::Config>,
     ) -> super::Result<super::SegmentKey> {
         let config = config_override.unwrap_or_else(|| self.backend.default_config());
-        let key = self
-            .backend
-            .find_segment(
-                &config,
-                namespace,
-                req,
-            )
-            .await?;
+        let key = self.backend.find_segment(&config, namespace, req).await?;
         Ok(key)
     }
 

libsql-wal/src/storage/backend/mod.rs

@@ -1,6 +1,6 @@
 #![allow(dead_code)]
-use std::sync::Arc;
 use std::future::Future;
+use std::sync::Arc;
 
 use chrono::{DateTime, Utc};
 use fst::Map;

libsql-wal/src/storage/backend/s3.rs

@@ -38,7 +38,8 @@ pub struct S3Backend<IO> {
     client: Client,
     default_config: Arc<S3Config>,
     io: IO,
-} impl S3Backend<StdIO> {
+}
+impl S3Backend<StdIO> {
     pub async fn from_sdk_config(
         aws_config: SdkConfig,
         bucket: String,
@@ -911,8 +912,11 @@ mod tests {
             .unwrap();
         assert_eq!(key.start_frame_no, 1);
         assert_eq!(key.end_frame_no, 64);
-        
-        let index = storage.fetch_segment_index(&s3_config, &ns, &key).await.unwrap();
+
+        let index = storage
+            .fetch_segment_index(&s3_config, &ns, &key)
+            .await
+            .unwrap();
         assert_eq!(index.get(42u32.to_be_bytes()).unwrap(), 42);
     }
 }

libsql-wal/src/storage/mod.rs

@@ -569,7 +569,9 @@ impl<IO: Io> Storage for TestStorage<IO> {
     ) -> Result<SegmentKey> {
         let inner = self.inner.lock().await;
         if inner.store {
-            let FindSegmentReq::EndFrameNoLessThan(fno) = req else { panic!("unsupported lookup by ts") };
+            let FindSegmentReq::EndFrameNoLessThan(fno) = req else {
+                panic!("unsupported lookup by ts")
+            };
             if let Some(segs) = inner.stored.get(namespace) {
                 let Some((key, _path)) = segs.iter().find(|(k, _)| k.includes(fno)) else {
                     return Err(Error::SegmentNotFound(req));