Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-16 22:44:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Move comment into docstring

Browse Source
This commit is contained in:
Erik Johnston 2015-04-08 14:01:22 +01:00
parent 638be5a6b9
commit 5bc41fe9f8
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
synapse/notifier.py
View File

@ -168,7 +168,6 @@ class Notifier(object):
room_listeners = self.room_to_listeners.get(room_id, set()) room_listeners = self.room_to_listeners.get(room_id, set())
# Remove any 'stale' listeners.
_discard_if_notified(room_listeners) _discard_if_notified(room_listeners)
listeners = room_listeners.copy() listeners = room_listeners.copy()
@ -176,7 +175,6 @@ class Notifier(object):
for user in extra_users: for user in extra_users:
user_listeners = self.user_to_listeners.get(user, set()) user_listeners = self.user_to_listeners.get(user, set())
# Remove any 'stale' listeners.
_discard_if_notified(user_listeners) _discard_if_notified(user_listeners)
listeners |= user_listeners listeners |= user_listeners
@ -192,7 +190,6 @@ class Notifier(object):
appservice, set() appservice, set()
) )
# Remove any 'stale' listeners.
_discard_if_notified(app_listeners) _discard_if_notified(app_listeners)
listeners |= app_listeners listeners |= app_listeners
@ -248,7 +245,6 @@ class Notifier(object):
for user in users: for user in users:
user_listeners = self.user_to_listeners.get(user, set()) user_listeners = self.user_to_listeners.get(user, set())
# Remove any 'stale' listeners.
_discard_if_notified(user_listeners) _discard_if_notified(user_listeners)
listeners |= user_listeners listeners |= user_listeners
@ -256,7 +252,6 @@ class Notifier(object):
for room in rooms: for room in rooms:
room_listeners = self.room_to_listeners.get(room, set()) room_listeners = self.room_to_listeners.get(room, set())
# Remove any 'stale' listeners.
_discard_if_notified(room_listeners) _discard_if_notified(room_listeners)
listeners |= room_listeners listeners |= room_listeners
@ -463,6 +458,8 @@ class Notifier(object):
def _discard_if_notified(listener_set): def _discard_if_notified(listener_set):
"""Remove any 'stale' listeners from the given set.
"""
to_discard = set() to_discard = set()
for l in listener_set: for l in listener_set:
if l.notified(): if l.notified():