RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-07 01:57:46 +04:00
parent 11ee819c93
commit 49f8ec9ec8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pybtc/connector/block_loader.py
View File

@ -139,10 +139,10 @@ class Worker:
self.in_reader = in_reader self.in_reader = in_reader
signal.signal(signal.SIGTERM, self.terminate) signal.signal(signal.SIGTERM, self.terminate)
self.loop.create_task(self.message_loop()) self.loop.create_task(self.message_loop())
self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout)
self.loop.run_forever() self.loop.run_forever()
async def message_loop(self): async def message_loop(self):
self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout)
self.reader = await self.get_pipe_reader(self.in_reader) self.reader = await self.get_pipe_reader(self.in_reader)
while True: while True:
msg_type, msg = await self.pipe_get_msg(self.reader) msg_type, msg = await self.pipe_get_msg(self.reader)