forked from LBRYCommunity/lbry-sdk
new_touched
This commit is contained in:
parent
20dad7f07f
commit
8dfa2767ec
1 changed files with 1 additions and 1 deletions
|
@ -660,7 +660,7 @@ class SessionManager:
|
||||||
if touched or (height_changed and self.mempool_statuses):
|
if touched or (height_changed and self.mempool_statuses):
|
||||||
notified_hashxs = 0
|
notified_hashxs = 0
|
||||||
notified_sessions = 0
|
notified_sessions = 0
|
||||||
to_notify = touched.union(self.mempool_statuses.keys() if height_changed else new_touched.intersection(self.mempool_statuses.keys()))
|
to_notify = touched if height_changed else new_touched
|
||||||
for hashX in to_notify:
|
for hashX in to_notify:
|
||||||
for session_id in self.hashx_subscriptions_by_session[hashX]:
|
for session_id in self.hashx_subscriptions_by_session[hashX]:
|
||||||
asyncio.create_task(self.sessions[session_id].send_history_notification(hashX))
|
asyncio.create_task(self.sessions[session_id].send_history_notification(hashX))
|
||||||
|
|
Loading…
Reference in a new issue