forked from MirrorHub/synapse
commit
bde97b988a
1 changed files with 2 additions and 2 deletions
|
@ -352,10 +352,10 @@ class Notifier(object):
|
||||||
after_id = getattr(after_token, keyname)
|
after_id = getattr(after_token, keyname)
|
||||||
if before_id == after_id:
|
if before_id == after_id:
|
||||||
continue
|
continue
|
||||||
stuff, new_key = yield source.get_new_events_for_user(
|
new_events, new_key = yield source.get_new_events_for_user(
|
||||||
user, getattr(from_token, keyname), limit,
|
user, getattr(from_token, keyname), limit,
|
||||||
)
|
)
|
||||||
events.extend(stuff)
|
events.extend(new_events)
|
||||||
end_token = end_token.copy_and_replace(keyname, new_key)
|
end_token = end_token.copy_and_replace(keyname, new_key)
|
||||||
|
|
||||||
if events:
|
if events:
|
||||||
|
|
Loading…
Reference in a new issue