From 41e838df5e7482d0cfd812d1a9da21b667fd8a21 Mon Sep 17 00:00:00 2001 From: Mariusz Klochowicz Date: Thu, 21 Oct 2021 17:46:44 +1030 Subject: [PATCH] Remove unnecessary async move --- daemon/src/maker.rs | 43 +++++++++++++++++++------------------------ 1 file changed, 19 insertions(+), 24 deletions(-) diff --git a/daemon/src/maker.rs b/daemon/src/maker.rs index 490f161..d5fa294 100644 --- a/daemon/src/maker.rs +++ b/daemon/src/maker.rs @@ -205,30 +205,25 @@ async fn main() -> Result<()> { .unwrap(); let ActorSystem { - cfd_actor_addr, - cfd_feed_receiver, - order_feed_receiver, - update_cfd_feed_receiver, - } = - ActorSystem::new( - db, - wallet.clone(), - oracle, - |cfds, channel| oracle::Actor::new(cfds, channel), - { - |channel, cfds| { - let electrum = opts.network.electrum().to_string(); - async move { - monitor::Actor::new(electrum, channel, cfds.clone()).await - } - } - }, - |channel0, channel1| { - maker_inc_connections::Actor::new(channel0, channel1) - }, - listener, - ) - .await; + cfd_actor_addr, + cfd_feed_receiver, + order_feed_receiver, + update_cfd_feed_receiver, + } = ActorSystem::new( + db, + wallet.clone(), + oracle, + |cfds, channel| oracle::Actor::new(cfds, channel), + { + |channel, cfds| { + let electrum = opts.network.electrum().to_string(); + monitor::Actor::new(electrum, channel, cfds) + } + }, + |channel0, channel1| maker_inc_connections::Actor::new(channel0, channel1), + listener, + ) + .await; tokio::spawn(wallet_sync::new(wallet, wallet_feed_sender));