fix attribute error
This commit is contained in:
parent
ddae84abb3
commit
1beb13dd80
1 changed files with 2 additions and 1 deletions
|
@ -284,12 +284,13 @@ class Network:
|
||||||
|
|
||||||
async def subscribe_address(self, address, *addresses):
|
async def subscribe_address(self, address, *addresses):
|
||||||
addresses = list((address, ) + addresses)
|
addresses = list((address, ) + addresses)
|
||||||
|
server_addr_and_port = self.client.server_address_and_port # on disconnect client will be None
|
||||||
try:
|
try:
|
||||||
return await self.rpc('blockchain.address.subscribe', addresses, True)
|
return await self.rpc('blockchain.address.subscribe', addresses, True)
|
||||||
except asyncio.TimeoutError:
|
except asyncio.TimeoutError:
|
||||||
log.warning(
|
log.warning(
|
||||||
"timed out subscribing to addresses from %s:%i",
|
"timed out subscribing to addresses from %s:%i",
|
||||||
*self.client.server_address_and_port
|
*server_addr_and_port
|
||||||
)
|
)
|
||||||
# abort and cancel, we can't lose a subscription, it will happen again on reconnect
|
# abort and cancel, we can't lose a subscription, it will happen again on reconnect
|
||||||
if self.client:
|
if self.client:
|
||||||
|
|
Loading…
Reference in a new issue