diff options
| author | David Robertson <davidr@element.io> | 2023-10-24 14:23:19 +0100 |
|---|---|---|
| committer | David Robertson <davidr@element.io> | 2023-10-24 14:23:19 +0100 |
| commit | c0d2f7649e2951ed8a91532adf1f6acceeb0f06f (patch) | |
| tree | 92dfd202e2316fa3bf3f33c47433de651dd0e880 /synapse/replication/tcp/streams/events.py | |
| parent | Add test case to detect dodgy b64 encoding (diff) | |
| parent | Rework alias and public room list rules docs (#16541) (diff) | |
| download | synapse-c0d2f7649e2951ed8a91532adf1f6acceeb0f06f.tar.xz | |
Merge branch 'develop' of github.com:matrix-org/synapse into develop
Diffstat (limited to 'synapse/replication/tcp/streams/events.py')
| -rw-r--r-- | synapse/replication/tcp/streams/events.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/synapse/replication/tcp/streams/events.py b/synapse/replication/tcp/streams/events.py index da6d948e1b..38823113d8 100644 --- a/synapse/replication/tcp/streams/events.py +++ b/synapse/replication/tcp/streams/events.py @@ -19,10 +19,10 @@ from typing import TYPE_CHECKING, Iterable, Optional, Tuple, Type, TypeVar, cast import attr from synapse.replication.tcp.streams._base import ( - Stream, StreamRow, StreamUpdateResult, Token, + _StreamFromIdGen, ) if TYPE_CHECKING: @@ -139,7 +139,7 @@ _EventRows: Tuple[Type[BaseEventsStreamRow], ...] = ( TypeToRow = {Row.TypeId: Row for Row in _EventRows} -class EventsStream(Stream): +class EventsStream(_StreamFromIdGen): """We received a new event, or an event went from being an outlier to not""" NAME = "events" @@ -147,9 +147,7 @@ class EventsStream(Stream): def __init__(self, hs: "HomeServer"): self._store = hs.get_datastores().main super().__init__( - hs.get_instance_name(), - self._store._stream_id_gen.get_current_token_for_writer, - self._update_function, + hs.get_instance_name(), self._update_function, self._store._stream_id_gen ) async def _update_function( |