forked from LBRYCommunity/lbry-sdk
update fetcher
This commit is contained in:
parent
ec3e365b3c
commit
d4193c55ae
2 changed files with 4 additions and 1 deletions
|
@ -600,6 +600,9 @@ class LBRYcrdWallet(LBRYWallet):
|
||||||
def get_nametrie(self):
|
def get_nametrie(self):
|
||||||
return threads.deferToThread(self._get_nametrie_rpc)
|
return threads.deferToThread(self._get_nametrie_rpc)
|
||||||
|
|
||||||
|
def get_claims_from_tx(self, txid):
|
||||||
|
return self._get_claims_from_tx(txid)
|
||||||
|
|
||||||
def start_miner(self):
|
def start_miner(self):
|
||||||
d = threads.deferToThread(self._get_gen_status_rpc)
|
d = threads.deferToThread(self._get_gen_status_rpc)
|
||||||
d.addCallback(lambda status: threads.deferToThread(self._set_gen_status_rpc, True) if not status
|
d.addCallback(lambda status: threads.deferToThread(self._set_gen_status_rpc, True) if not status
|
||||||
|
|
|
@ -136,7 +136,7 @@ class FetcherDaemon(object):
|
||||||
|
|
||||||
def _get_names(self):
|
def _get_names(self):
|
||||||
d = self.wallet.get_blockchain_info()
|
d = self.wallet.get_blockchain_info()
|
||||||
d.addCallback(lambda c: get_new_streams if c != self.lastbestblock else [])
|
d.addCallback(lambda c: get_new_streams(c) if c != self.lastbestblock else [])
|
||||||
|
|
||||||
def get_new_streams(c):
|
def get_new_streams(c):
|
||||||
self.lastbestblock = c
|
self.lastbestblock = c
|
||||||
|
|
Loading…
Reference in a new issue