diff --git a/electrum/lnbase.py b/electrum/lnbase.py
index c9a680bfa..2d5e6eb04 100644
--- a/electrum/lnbase.py
+++ b/electrum/lnbase.py
@@ -463,7 +463,7 @@ class Peer(PrintError):
         while True:
             self.ping_if_required()
             msg = await self.read_message()
-            await self.process_message(msg)
+            self.process_message(msg)
 
     def close_and_cleanup(self):
         try:
diff --git a/electrum/lnworker.py b/electrum/lnworker.py
index b1d9a8362..839d8b4ae 100644
--- a/electrum/lnworker.py
+++ b/electrum/lnworker.py
@@ -235,7 +235,7 @@ class LNWorker(PrintError):
         none_idx = tx._inputs[0]["signatures"].index(None)
         tx.add_signature_to_txin(0, none_idx, bh2u(remote_sig))
         assert tx.is_complete()
-        return self.network.broadcast_transaction(tx)
+        return self.network.broadcast_transaction_from_non_network_thread(tx)
 
     def _get_next_peers_to_try(self) -> Sequence[LNPeerAddr]:
         now = time.time()