diff options
| author | Erik Johnston <erik@matrix.org> | 2020-09-29 21:48:33 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-29 21:48:33 +0100 |
| commit | ea70f1c362dc4bd6c0f8a67e16ed0971fe095e5b (patch) | |
| tree | 83a37ad1ffa3e1432dc4ca281a0cfec5ed600445 /synapse/handlers/room.py | |
| parent | Update description of server_name config option (#8415) (diff) | |
| download | synapse-ea70f1c362dc4bd6c0f8a67e16ed0971fe095e5b.tar.xz | |
Various clean ups to room stream tokens. (#8423)
Diffstat (limited to 'synapse/handlers/room.py')
| -rw-r--r-- | synapse/handlers/room.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/room.py b/synapse/handlers/room.py index 11bf146bed..836b3f381a 100644 --- a/synapse/handlers/room.py +++ b/synapse/handlers/room.py @@ -1134,14 +1134,14 @@ class RoomEventSource: events[:] = events[:limit] if events: - end_key = RoomStreamToken.parse(events[-1].internal_metadata.after) + end_key = events[-1].internal_metadata.after else: end_key = to_key return (events, end_key) def get_current_key(self) -> RoomStreamToken: - return RoomStreamToken(None, self.store.get_room_max_stream_ordering()) + return self.store.get_room_max_token() def get_current_key_for_room(self, room_id: str) -> Awaitable[str]: return self.store.get_room_events_max_id(room_id) |