1 files changed, 1 insertions, 5 deletions
diff --git a/futures/src/subscription.rs b/futures/src/subscription.rs
index 0085886d..0479c63c 100644
--- a/futures/src/subscription.rs
+++ b/futures/src/subscription.rs
@@ -183,11 +183,7 @@ where
 
         let mapper = self.mapper;
 
-        Box::pin(
-            self.recipe
-                .stream(input)
-                .map(move |element| mapper(element)),
-        )
+        Box::pin(self.recipe.stream(input).map(mapper))
     }
 }