asdasdsada

This commit is contained in:
Thomas Zarebczan 2018-11-16 16:19:09 -05:00
parent 5d6aed5104
commit 50758dad2c

View file

@ -384,13 +384,12 @@ class Interface(PrintError):
async def run_fetch_blocks(self):
header_queue = asyncio.Queue()
await self.session.subscribe('blockchain.headers.subscribe', [], header_queue)
await self.session.subscribe('blockchain.headers.subscribe', [True], header_queue)
while True:
item = await header_queue.get()
raw_header = item[0]
self.print_error(raw_header)
print(raw_header)
log(raw_header)
height = raw_header['block_height']
header = blockchain.deserialize_header(bfh(raw_header['hex']), height)
self.tip_header = header