OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-03-14 11:44:04 +01:00
Code Issues Projects Releases Packages Wiki Activity

Remove redundant async move blocks

Browse source
This commit is contained in:
Hirrolot 2022-04-13 13:40:27 +06:00
parent e4459c408d
commit 6a83fa5604
1 changed files with 14 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
src/dispatching/dispatcher.rs
View file

@ -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
}