From 31fc7e62b4c469bf03f43fc8ff7a1c483f7ca299 Mon Sep 17 00:00:00 2001
From: Taiki Endo <te316e89@gmail.com>
Date: Tue, 22 Oct 2019 14:30:30 +0900
Subject: [PATCH] Remove redundant closures

---
 .../benchmarks/futures-channel.rs             | 28 ++++++++-----------
 crossbeam-skiplist/src/map.rs                 |  3 +-
 2 files changed, 12 insertions(+), 19 deletions(-)

diff --git a/crossbeam-channel/benchmarks/futures-channel.rs b/crossbeam-channel/benchmarks/futures-channel.rs
index d97b53964..c26778bc1 100644
--- a/crossbeam-channel/benchmarks/futures-channel.rs
+++ b/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(()))
                 }));
             }
 
diff --git a/crossbeam-skiplist/src/map.rs b/crossbeam-skiplist/src/map.rs
index c1c0a71e3..93ddb7fc9 100644
--- a/crossbeam-skiplist/src/map.rs
+++ b/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);
         }
     }
 }