forked from LBRYCommunity/lbry-sdk
wait for wallet subscriptions
This commit is contained in:
parent
dc7193bb8f
commit
dffaf745ec
2 changed files with 5 additions and 1 deletions
|
@ -16,6 +16,7 @@ at anytime.
|
||||||
|
|
||||||
### Changed
|
### Changed
|
||||||
* Added optional `address` and `include_unconfirmed` params to `jsonrpc_wallet_balance` method
|
* Added optional `address` and `include_unconfirmed` params to `jsonrpc_wallet_balance` method
|
||||||
|
* Wait for subscriptions before announcing wallet has finished starting
|
||||||
|
|
||||||
### Fixed
|
### Fixed
|
||||||
* fix stream_cost_estimate throwing exception on non decodeable claims
|
* fix stream_cost_estimate throwing exception on non decodeable claims
|
||||||
|
|
|
@ -913,6 +913,9 @@ class LBRYumWallet(Wallet):
|
||||||
d.addCallback(lambda _: self._start_check.start(.1))
|
d.addCallback(lambda _: self._start_check.start(.1))
|
||||||
d.addCallback(lambda _: network_start_d)
|
d.addCallback(lambda _: network_start_d)
|
||||||
d.addCallback(lambda _: self._load_blockchain())
|
d.addCallback(lambda _: self._load_blockchain())
|
||||||
|
d.addCallback(lambda _: log.info("Subscribing to addresses"))
|
||||||
|
d.addCallback(lambda _: self.wallet.wait_until_synchronized(lambda _: None))
|
||||||
|
d.addCallback(lambda _: log.info("Synchronized wallet"))
|
||||||
return d
|
return d
|
||||||
|
|
||||||
def _stop(self):
|
def _stop(self):
|
||||||
|
|
Loading…
Reference in a new issue