From 910e85ec0146b87d236d0e9590fcf4b28aa7e0fb Mon Sep 17 00:00:00 2001 From: ThomasV Date: Mon, 15 Oct 2018 10:49:33 +0200 Subject: [PATCH] future and callback are not needed here --- electrum/lnworker.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/electrum/lnworker.py b/electrum/lnworker.py index b41892ab4..1344cc443 100644 --- a/electrum/lnworker.py +++ b/electrum/lnworker.py @@ -112,13 +112,12 @@ class LNWorker(PrintError): return self._last_tried_peer[peer_addr] = time.time() self.print_error("adding peer", peer_addr) - fut = asyncio.ensure_future(asyncio.open_connection(peer_addr.host, peer_addr.port)) - def cb(fut): - reader, writer = fut.result() + async def _init_peer(): + reader, writer = await asyncio.open_connection(peer_addr.host, peer_addr.port) transport = InitiatorSession(self.node_keypair.privkey, node_id, reader, writer) peer.transport = transport - asyncio.run_coroutine_threadsafe(self.network.main_taskgroup.spawn(peer.main_loop()), self.network.asyncio_loop) - fut.add_done_callback(cb) + await self.network.main_taskgroup.spawn(peer.main_loop()) + asyncio.ensure_future(_init_peer()) peer = Peer(self, peer_addr, request_initial_sync=self.config.get("request_initial_sync", True)) self.peers[node_id] = peer self.network.trigger_callback('ln_status')