Fix and format

bastion-rs · Oct 24, 2019 · 5f358ef · 5f358ef
1 parent 58e0c72
commit 5f358ef
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 12 deletions.
diff --git a/lightproc/examples/proc_panic.rs b/lightproc/examples/proc_panic.rs
@@ -1,5 +1,5 @@
 use std::future::Future;
-use std::sync::Arc;
+
 use std::thread;
 
 use crossbeam::channel::{unbounded, Sender};
@@ -9,8 +9,6 @@ use lightproc::prelude::*;
 
 use lightproc::recoverable_handle::RecoverableHandle;
 
-use std::sync::atomic::AtomicUsize;
-
 fn spawn_on_thread<F, R>(future: F) -> RecoverableHandle<R>
 where
     F: Future<Output = R> + Send + 'static,
@@ -38,9 +36,15 @@ where
         schedule,
         ProcStack::default()
             .with_pid(1)
-            .with_before_start(|| { println!("Before start"); })
-            .with_after_complete(|| { println!("After complete"); })
-            .with_after_panic(|| { println!("After panic"); })
+            .with_before_start(|| {
+                println!("Before start");
+            })
+            .with_after_complete(|| {
+                println!("After complete");
+            })
+            .with_after_panic(|| {
+                println!("After panic");
+            }),
     );
 
     proc.schedule();

diff --git a/lightproc/examples/proc_run.rs b/lightproc/examples/proc_run.rs
@@ -7,7 +7,6 @@ use std::thread;
 use crossbeam::channel;
 use futures::executor;
 use lightproc::prelude::*;
-use std::sync::atomic::AtomicUsize;
 
 fn spawn_on_thread<F, R>(fut: F) -> ProcHandle<R>
 where
@@ -29,8 +28,12 @@ where
         schedule,
         ProcStack::default()
             .with_pid(1)
-            .with_before_start(|| { println!("Before start"); })
-            .with_after_complete(|| { println!("After complete"); })
+            .with_before_start(|| {
+                println!("Before start");
+            })
+            .with_after_complete(|| {
+                println!("After complete");
+            }),
     );
 
     proc.schedule();

diff --git a/lightproc/src/proc_stack.rs b/lightproc/src/proc_stack.rs
@@ -24,23 +24,23 @@ impl ProcStack {
 
     pub fn with_before_start<T>(mut self, callback: T) -> Self
     where
-        T: Fn() + Send + Sync + 'static
+        T: Fn() + Send + Sync + 'static,
     {
         self.before_start = Some(Arc::new(callback));
         self
     }
 
     pub fn with_after_complete<T>(mut self, callback: T) -> Self
     where
-        T: Fn() + Send + Sync + 'static
+        T: Fn() + Send + Sync + 'static,
     {
         self.after_complete = Some(Arc::new(callback));
         self
     }
 
     pub fn with_after_panic<T>(mut self, callback: T) -> Self
     where
-        T: Fn() + Send + Sync + 'static
+        T: Fn() + Send + Sync + 'static,
     {
         self.after_panic = Some(Arc::new(callback));
         self