mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-08-23 17:47:31 +00:00
asdsadsadas
This commit is contained in:
parent
f1e17f76b1
commit
5d6aed5104
1 changed files with 3 additions and 2 deletions
|
@ -61,8 +61,6 @@ class NotificationSession(RPCSession):
|
||||||
# will catch the exception, count errors, and at some point disconnect
|
# will catch the exception, count errors, and at some point disconnect
|
||||||
if isinstance(request, Notification):
|
if isinstance(request, Notification):
|
||||||
params, result = request.args[:-1], request.args[-1]
|
params, result = request.args[:-1], request.args[-1]
|
||||||
self.print_error(params)
|
|
||||||
self.print_error(result)
|
|
||||||
key = self.get_hashable_key_for_rpc_call(request.method, params)
|
key = self.get_hashable_key_for_rpc_call(request.method, params)
|
||||||
if key in self.subscriptions:
|
if key in self.subscriptions:
|
||||||
self.cache[key] = result
|
self.cache[key] = result
|
||||||
|
@ -390,6 +388,9 @@ class Interface(PrintError):
|
||||||
while True:
|
while True:
|
||||||
item = await header_queue.get()
|
item = await header_queue.get()
|
||||||
raw_header = item[0]
|
raw_header = item[0]
|
||||||
|
self.print_error(raw_header)
|
||||||
|
print(raw_header)
|
||||||
|
log(raw_header)
|
||||||
height = raw_header['block_height']
|
height = raw_header['block_height']
|
||||||
header = blockchain.deserialize_header(bfh(raw_header['hex']), height)
|
header = blockchain.deserialize_header(bfh(raw_header['hex']), height)
|
||||||
self.tip_header = header
|
self.tip_header = header
|
||||||
|
|
Loading…
Add table
Reference in a new issue