Merge #438

438: Remove redundant closures r=jeehoonkang a=taiki-e



Co-authored-by: Taiki Endo <te316e89@gmail.com>

Author: bors[bot]

crossbeam-channel/benchmarks/futures-channel.rs

@@ -48,7 +48,7 @@ fn spsc_unbounded() {
             let (tx, rx) = mpsc::unbounded();
 
             cx.spawn(future::lazy(move |_| {
-                tx.send_all(stream::iter_ok((0..MESSAGES).map(|i| message::new(i))))
+                tx.send_all(stream::iter_ok((0..MESSAGES).map(message::new)))
                     .map_err(|_| panic!())
                     .and_then(|_| future::ok(()))
             }));
@@ -65,7 +65,7 @@ fn spsc_bounded(cap: usize) {
             let (tx, rx) = mpsc::channel(cap);
 
             cx.spawn(future::lazy(move |_| {
-                tx.send_all(stream::iter_ok((0..MESSAGES).map(|i| message::new(i))))
+                tx.send_all(stream::iter_ok((0..MESSAGES).map(message::new)))
                     .map_err(|_| panic!())
                     .and_then(|_| future::ok(()))
             }));
@@ -84,11 +84,9 @@ 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(message::new)))
+                        .map_err(|_| panic!())
+                        .and_then(|_| future::ok(()))
                 }));
             }
             drop(tx);
@@ -107,11 +105,9 @@ 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(message::new)))
+                        .map_err(|_| panic!())
+                        .and_then(|_| future::ok(()))
                 }));
             }
             drop(tx);
@@ -153,11 +149,9 @@ 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(message::new)))
+                        .map_err(|_| panic!())
+                        .and_then(|_| future::ok(()))
                 }));
             }
 

crossbeam-skiplist/src/map.rs

@@ -254,8 +254,7 @@ impl<'a, K, V> Drop for Entry<'a, K, V>
 {
     fn drop(&mut self) {
         unsafe {
-            ManuallyDrop::into_inner(ptr::read(&mut self.inner))
-                .release_with_pin(|| epoch::pin());
+            ManuallyDrop::into_inner(ptr::read(&mut self.inner)).release_with_pin(epoch::pin);
         }
     }
 }