From 6a83fa56044e157bd9af2f86aa327a5e83ba85a7 Mon Sep 17 00:00:00 2001 From: Hirrolot <hirrolot@gmail.com> Date: Wed, 13 Apr 2022 13:40:27 +0600 Subject: [PATCH] Remove redundant `async move` blocks --- src/dispatching/dispatcher.rs | 40 ++++++++++++----------------------- 1 file changed, 14 insertions(+), 26 deletions(-) diff --git a/src/dispatching/dispatcher.rs b/src/dispatching/dispatcher.rs index 9e8a2e78..60771555 100644 --- a/src/dispatching/dispatcher.rs +++ b/src/dispatching/dispatcher.rs @@ -317,20 +317,14 @@ where let deps = Arc::new(deps); - tokio::spawn(async move { - ReceiverStream::new(rx) - .for_each(|update| { - let deps = Arc::clone(&deps); - let handler = Arc::clone(&handler); - let default_handler = Arc::clone(&default_handler); - let error_handler = Arc::clone(&error_handler); + tokio::spawn(ReceiverStream::new(rx).for_each(move |update| { + let deps = Arc::clone(&deps); + let handler = Arc::clone(&handler); + let default_handler = Arc::clone(&default_handler); + let error_handler = Arc::clone(&error_handler); - async move { - handle_update(update, deps, handler, default_handler, error_handler).await; - } - }) - .await; - }); + handle_update(update, deps, handler, default_handler, error_handler) + })); tx } @@ -348,20 +342,14 @@ where let deps = Arc::new(deps); - tokio::spawn(async move { - ReceiverStream::new(rx) - .for_each_concurrent(None, |update| { - let deps = Arc::clone(&deps); - let handler = Arc::clone(&handler); - let default_handler = Arc::clone(&default_handler); - let error_handler = Arc::clone(&error_handler); + tokio::spawn(ReceiverStream::new(rx).for_each_concurrent(None, move |update| { + let deps = Arc::clone(&deps); + let handler = Arc::clone(&handler); + let default_handler = Arc::clone(&default_handler); + let error_handler = Arc::clone(&error_handler); - async move { - handle_update(update, deps, handler, default_handler, error_handler).await; - } - }) - .await; - }); + handle_update(update, deps, handler, default_handler, error_handler) + })); tx }