cargo fmt

src/bin/darkfid.rs

@@ -247,11 +247,11 @@ fn main() -> Result<()> {
 }
 
 //// $ cargo test test_ten_clients_simultaneously --bin darkfid
-        //this will run 10 clients simultaneously
+//this will run 10 clients simultaneously
 
 //// $ cargo test test_subscriber --bin darkfid
-        // Run Client A and send 10 slabs
-        // Client B should receive 10 slabs from subscriber
+// Run Client A and send 10 slabs
+// Client B should receive 10 slabs from subscriber
 #[cfg(test)]
 mod test {
 
@@ -347,7 +347,6 @@ mod test {
         }
     }
 
-
     #[test]
     fn test_subscriber() {
         setup_log();
@@ -386,7 +385,6 @@ mod test {
                 client.put_slab(slab.clone()).await.unwrap();
                 client.put_slab(slab.clone()).await.unwrap();
                 client.put_slab(slab.clone()).await.unwrap();
-
             });
         });
         // Client B
@@ -422,7 +420,8 @@ mod test {
                             client.start_subscriber(sub_addr, ex.clone()).await.unwrap();
 
                         ex.clone()
-                            .spawn(subscribe(gateway_slabs_sub, "B".to_string())).detach();
+                            .spawn(subscribe(gateway_slabs_sub, "B".to_string()))
+                            .detach();
 
                         // start gateway client
                         client.start().await.unwrap();

src/blockchain/slab.rs

@@ -1,7 +1,6 @@
 use crate::serial::{Decodable, Encodable};
 use crate::Result;
 
-
 #[derive(Clone, Debug)]
 pub struct Slab {
     asset_type: String,

src/service/gateway.rs

@@ -217,7 +217,6 @@ impl GatewayClient {
         if last_index > 0 {
             for index in (local_last_index + 1)..(last_index + 1) {
                 if let None = self.get_slab(index).await? {
-                    warn!("Index not exist");
                     break;
                 }
             }