From 49f8ec9ec8d85f6cffe7ec870022836d8a76fce1 Mon Sep 17 00:00:00 2001 From: 4tochka Date: Tue, 7 May 2019 01:57:46 +0400 Subject: [PATCH] connector --- pybtc/connector/block_loader.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py index c174540..d0dbb78 100644 --- a/pybtc/connector/block_loader.py +++ b/pybtc/connector/block_loader.py @@ -139,10 +139,10 @@ class Worker: self.in_reader = in_reader signal.signal(signal.SIGTERM, self.terminate) self.loop.create_task(self.message_loop()) - self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout) self.loop.run_forever() 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) while True: msg_type, msg = await self.pipe_get_msg(self.reader)