From 0eaa1ff82edd2d44927dec97fce06f530ad254f9 Mon Sep 17 00:00:00 2001 From: Thomas Eizinger Date: Mon, 15 Nov 2021 18:35:22 +1100 Subject: [PATCH] Migrate `do_send_async` to `send` These handlers never fail and we are always connected. --- daemon/src/maker_cfd.rs | 6 ++++-- daemon/src/taker_cfd.rs | 6 ++++-- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/daemon/src/maker_cfd.rs b/daemon/src/maker_cfd.rs index cbb175d..1216b25 100644 --- a/daemon/src/maker_cfd.rs +++ b/daemon/src/maker_cfd.rs @@ -622,8 +622,9 @@ where tokio::spawn(async move { let dlc = contract_future.await; - this.do_send_async(CfdSetupCompleted { order_id, dlc }) + this.send(CfdSetupCompleted { order_id, dlc }) .await + .expect("always connected to ourselves"); }); // 6. Record that we are in an active contract setup @@ -789,8 +790,9 @@ where tokio::spawn(async move { let dlc = contract_future.await; - this.do_send_async(CfdRollOverCompleted { order_id, dlc }) + this.send(CfdRollOverCompleted { order_id, dlc }) .await + .expect("always connected to ourselves") }); self.remove_pending_proposal(&order_id) diff --git a/daemon/src/taker_cfd.rs b/daemon/src/taker_cfd.rs index 3242dd8..dd1219c 100644 --- a/daemon/src/taker_cfd.rs +++ b/daemon/src/taker_cfd.rs @@ -518,8 +518,9 @@ where tokio::spawn(async move { let dlc = contract_future.await; - this.do_send_async(CfdSetupCompleted { order_id, dlc }) + this.send(CfdSetupCompleted { order_id, dlc }) .await + .expect("always connected to ourselves") }); self.setup_state = SetupState::Active { sender }; @@ -582,8 +583,9 @@ where tokio::spawn(async move { let dlc = contract_future.await; - this.do_send_async(CfdRollOverCompleted { order_id, dlc }) + this.send(CfdRollOverCompleted { order_id, dlc }) .await + .expect("always connected to ourselves") }); self.remove_pending_proposal(&order_id)