fmt

Author: rklaehn

src/store/fs/bao_file.rs

@@ -20,12 +20,12 @@ use bao_tree::{
 use bytes::{Bytes, BytesMut};
 use derive_more::Debug;
 use irpc::channel::mpsc;
-use super::util::watch;
 use tracing::{debug, error, info, trace};
 
 use super::{
     entry_state::{DataLocation, EntryState, OutboardLocation},
     options::{Options, PathOptions},
+    util::watch,
     BaoFilePart,
 };
 use crate::{

src/store/fs/util/watch.rs

@@ -53,7 +53,7 @@ impl<T> Drop for Sender<T> {
         self.0.value.borrow_mut().dropped = true;
         self.0.notify.notify_waiters();
     }
-}   
+}
 
 impl<T> Receiver<T> {
     pub async fn changed(&self) -> Result<(), error::RecvError> {
@@ -69,7 +69,7 @@ impl<T> Receiver<T> {
         AtomicRef::map(self.0.value.borrow(), |state| &state.value)
     }
 }
-    
+
 pub mod error {
     use std::{error::Error, fmt};
 
@@ -84,4 +84,4 @@ pub mod error {
     }
 
     impl Error for RecvError {}
-}
+}