diff options
| author | Erik Johnston <erik@matrix.org> | 2020-03-20 14:40:47 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-03-20 14:40:47 +0000 |
| commit | fdb13447167da0670dd6ad95fdf4a99cde450eb9 (patch) | |
| tree | 4e65824624e802bdaf04f3e289ec348fd4f3ab55 /synapse/handlers/presence.py | |
| parent | Convert some of the media REST code to async/await (#7110) (diff) | |
| download | synapse-fdb13447167da0670dd6ad95fdf4a99cde450eb9.tar.xz | |
Remove concept of a non-limited stream. (#7011)
Diffstat (limited to 'synapse/handlers/presence.py')
| -rw-r--r-- | synapse/handlers/presence.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/presence.py b/synapse/handlers/presence.py index 5526015ddb..6912165622 100644 --- a/synapse/handlers/presence.py +++ b/synapse/handlers/presence.py @@ -747,7 +747,7 @@ class PresenceHandler(object): return False - async def get_all_presence_updates(self, last_id, current_id): + async def get_all_presence_updates(self, last_id, current_id, limit): """ Gets a list of presence update rows from between the given stream ids. Each row has: @@ -762,7 +762,7 @@ class PresenceHandler(object): """ # TODO(markjh): replicate the unpersisted changes. # This could use the in-memory stores for recent changes. - rows = await self.store.get_all_presence_updates(last_id, current_id) + rows = await self.store.get_all_presence_updates(last_id, current_id, limit) return rows def notify_new_event(self): |