From a6e466e37ea0da4a316b39bb45f48f95dde2b4a7 Mon Sep 17 00:00:00 2001 From: TheLazieR Yip Date: Thu, 11 Jan 2018 17:05:18 +0700 Subject: [PATCH] Update DashElectrumX follow notification process of ElectrumX. (#346) --- server/session.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/session.py b/server/session.py index 4f6b6f9..bcd6081 100644 --- a/server/session.py +++ b/server/session.py @@ -486,12 +486,12 @@ class DashElectrumX(ElectrumX): 'masternode.subscribe': self.masternode_subscribe, }) - async def notify(self, height, touched): + def notify(self, height, touched): '''Notify the client about changes in masternode list.''' - await super().notify(height, touched) + result = super().notify(height, touched) for masternode in self.mns: - status = await self.daemon.masternode_list(['status', masternode]) + status = self.daemon.masternode_list(['status', masternode]) payload = { 'id': None, 'method': 'masternode.subscribe', @@ -499,6 +499,7 @@ class DashElectrumX(ElectrumX): 'result': status.get(masternode), } self.send_binary(self.encode_payload(payload)) + return result def server_version(self, client_name=None, protocol_version=None): '''Returns the server version as a string.