Rustfmt everything

crossbeam-rs · Feb 21, 2019 · 2076c5a · 2076c5a
1 parent ea2f68e
commit 2076c5a
Show file tree

Hide file tree

Showing 59 changed files with 729 additions and 522 deletions.
diff --git a/crossbeam-channel/benchmarks/atomicring.rs b/crossbeam-channel/benchmarks/atomicring.rs
@@ -52,7 +52,8 @@ fn spsc(cap: usize) {
                 }
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc(cap: usize) {
@@ -82,7 +83,8 @@ fn mpsc(cap: usize) {
                 }
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc(cap: usize) {
@@ -115,7 +117,8 @@ fn mpmc(cap: usize) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/atomicringqueue.rs b/crossbeam-channel/benchmarks/atomicringqueue.rs
@@ -46,7 +46,8 @@ fn spsc(cap: usize) {
         for _ in 0..MESSAGES {
             q.pop();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc(cap: usize) {
@@ -70,7 +71,8 @@ fn mpsc(cap: usize) {
         for _ in 0..MESSAGES {
             q.pop();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc(cap: usize) {
@@ -98,7 +100,8 @@ fn mpmc(cap: usize) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/bus.rs b/crossbeam-channel/benchmarks/bus.rs
@@ -34,7 +34,8 @@ fn spsc(cap: usize) {
         for _ in 0..MESSAGES {
             rx.recv().unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/chan.rs b/crossbeam-channel/benchmarks/chan.rs
@@ -39,7 +39,8 @@ fn spsc(cap: Option<usize>) {
         for _ in 0..MESSAGES {
             rx.recv().unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc(cap: Option<usize>) {
@@ -57,7 +58,8 @@ fn mpsc(cap: Option<usize>) {
         for _ in 0..MESSAGES {
             rx.recv().unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc(cap: Option<usize>) {
@@ -79,7 +81,8 @@ fn mpmc(cap: Option<usize>) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn select_rx(cap: Option<usize>) {
@@ -108,7 +111,8 @@ fn select_rx(cap: Option<usize>) {
                 rx3.recv() -> m => assert!(m.is_some()),
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn select_both(cap: Option<usize>) {
@@ -153,7 +157,8 @@ fn select_both(cap: Option<usize>) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/crossbeam-channel.rs b/crossbeam-channel/benchmarks/crossbeam-channel.rs
@@ -40,7 +40,8 @@ fn spsc(cap: Option<usize>) {
         for _ in 0..MESSAGES {
             rx.recv().unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc(cap: Option<usize>) {
@@ -58,7 +59,8 @@ fn mpsc(cap: Option<usize>) {
         for _ in 0..MESSAGES {
             rx.recv().unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc(cap: Option<usize>) {
@@ -80,7 +82,8 @@ fn mpmc(cap: Option<usize>) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn select_rx(cap: Option<usize>) {
@@ -105,7 +108,8 @@ fn select_rx(cap: Option<usize>) {
             let index = case.index();
             case.recv(&chans[index].1).unwrap();
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn select_both(cap: Option<usize>) {
@@ -139,7 +143,8 @@ fn select_both(cap: Option<usize>) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/crossbeam-deque.rs b/crossbeam-channel/benchmarks/crossbeam-deque.rs
@@ -1,7 +1,7 @@
 extern crate crossbeam;
 extern crate crossbeam_deque as deque;
 
-use deque::{Worker, Steal};
+use deque::{Steal, Worker};
 use std::thread;
 
 mod message;
@@ -18,7 +18,7 @@ fn seq() {
 
     for _ in 0..MESSAGES {
         match rx.steal() {
-            Steal::Success(_) => {},
+            Steal::Success(_) => {}
             Steal::Retry => panic!(),
             Steal::Empty => panic!(),
         }
@@ -46,7 +46,8 @@ fn spsc() {
                 }
             }
         });
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/futures-channel.rs b/crossbeam-channel/benchmarks/futures-channel.rs
@@ -22,7 +22,8 @@ fn seq_unbounded() {
             drop(tx);
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn seq_bounded(cap: usize) {
@@ -36,7 +37,8 @@ fn seq_bounded(cap: usize) {
             drop(tx);
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn spsc_unbounded() {
@@ -52,7 +54,8 @@ fn spsc_unbounded() {
             }));
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn spsc_bounded(cap: usize) {
@@ -68,7 +71,8 @@ fn spsc_bounded(cap: usize) {
             }));
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn mpsc_unbounded() {
@@ -80,15 +84,18 @@ fn mpsc_unbounded() {
             for _ in 0..THREADS {
                 let tx = tx.clone();
                 cx.spawn(future::lazy(move |_| {
-                    tx.send_all(stream::iter_ok((0..MESSAGES / THREADS).map(|i| message::new(i))))
-                        .map_err(|_| panic!())
-                        .and_then(|_| future::ok(()))
+                    tx.send_all(stream::iter_ok(
+                        (0..MESSAGES / THREADS).map(|i| message::new(i)),
+                    ))
+                    .map_err(|_| panic!())
+                    .and_then(|_| future::ok(()))
                 }));
             }
             drop(tx);
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn mpsc_bounded(cap: usize) {
@@ -100,15 +107,18 @@ fn mpsc_bounded(cap: usize) {
             for _ in 0..THREADS {
                 let tx = tx.clone();
                 cx.spawn(future::lazy(move |_| {
-                    tx.send_all(stream::iter_ok((0..MESSAGES / THREADS).map(|i| message::new(i))))
-                        .map_err(|_| panic!())
-                        .and_then(|_| future::ok(()))
+                    tx.send_all(stream::iter_ok(
+                        (0..MESSAGES / THREADS).map(|i| message::new(i)),
+                    ))
+                    .map_err(|_| panic!())
+                    .and_then(|_| future::ok(()))
                 }));
             }
             drop(tx);
 
             rx.for_each(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn select_rx_unbounded() {
@@ -130,7 +140,8 @@ fn select_rx_unbounded() {
             stream::select_all(chans.into_iter().map(|(_, rx)| rx))
                 .for_each(|_| future::ok(()))
                 .and_then(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn select_rx_bounded(cap: usize) {
@@ -142,16 +153,19 @@ fn select_rx_bounded(cap: usize) {
             for (tx, _) in &chans {
                 let tx = tx.clone();
                 cx.spawn(future::lazy(move |_| {
-                    tx.send_all(stream::iter_ok((0..MESSAGES / THREADS).map(|i| message::new(i))))
-                        .map_err(|_| panic!())
-                        .and_then(|_| future::ok(()))
+                    tx.send_all(stream::iter_ok(
+                        (0..MESSAGES / THREADS).map(|i| message::new(i)),
+                    ))
+                    .map_err(|_| panic!())
+                    .and_then(|_| future::ok(()))
                 }));
             }
 
             stream::select_all(chans.into_iter().map(|(_, rx)| rx))
                 .for_each(|_| future::ok(()))
                 .and_then(|_| future::ok(()))
-        })).unwrap();
+        }))
+        .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/lockfree.rs b/crossbeam-channel/benchmarks/lockfree.rs
@@ -39,7 +39,8 @@ fn spsc() {
                 thread::yield_now();
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc() {
@@ -59,7 +60,8 @@ fn mpsc() {
                 thread::yield_now();
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc() {
@@ -83,7 +85,8 @@ fn mpmc() {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {

diff --git a/crossbeam-channel/benchmarks/mpmc.rs b/crossbeam-channel/benchmarks/mpmc.rs
@@ -51,7 +51,8 @@ fn spsc(cap: usize) {
                 }
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpsc(cap: usize) {
@@ -81,7 +82,8 @@ fn mpsc(cap: usize) {
                 }
             }
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn mpmc(cap: usize) {
@@ -115,7 +117,8 @@ fn mpmc(cap: usize) {
                 }
             });
         }
-    }).unwrap();
+    })
+    .unwrap();
 }
 
 fn main() {