tfuture and callback are not needed here - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 910e85ec0146b87d236d0e9590fcf4b28aa7e0fb
DIR parent 71afa3cc70ab22aeed8ce8b6bb19f78d29d1ec53
HTML Author: ThomasV <thomasv@electrum.org>
Date: Mon, 15 Oct 2018 10:49:33 +0200
future and callback are not needed here
Diffstat:
M electrum/lnworker.py | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
---
DIR diff --git a/electrum/lnworker.py b/electrum/lnworker.py
t@@ -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')