diff options
| author | Erik Johnston <erik@matrix.org> | 2020-01-16 09:16:12 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-16 09:16:12 +0000 |
| commit | 48c3a96886de64f3141ad68b8163cd2fc0c197ff (patch) | |
| tree | e8d6629579e6f7fba216e31bba04cf05781d258c /synapse/replication/tcp/streams/events.py | |
| parent | Fix purge_room admin API (#6711) (diff) | |
| download | synapse-48c3a96886de64f3141ad68b8163cd2fc0c197ff.tar.xz | |
Port synapse.replication.tcp to async/await (#6666)
* Port synapse.replication.tcp to async/await * Newsfile * Correctly document type of on_<FOO> functions as async * Don't be overenthusiastic with the asyncing....
Diffstat (limited to 'synapse/replication/tcp/streams/events.py')
| -rw-r--r-- | synapse/replication/tcp/streams/events.py | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/synapse/replication/tcp/streams/events.py b/synapse/replication/tcp/streams/events.py index 0843e5aa90..b3afabb8cd 100644 --- a/synapse/replication/tcp/streams/events.py +++ b/synapse/replication/tcp/streams/events.py @@ -19,8 +19,6 @@ from typing import Tuple, Type import attr -from twisted.internet import defer - from ._base import Stream @@ -122,16 +120,15 @@ class EventsStream(Stream): super(EventsStream, self).__init__(hs) - @defer.inlineCallbacks - def update_function(self, from_token, current_token, limit=None): - event_rows = yield self._store.get_all_new_forward_event_rows( + async def update_function(self, from_token, current_token, limit=None): + event_rows = await self._store.get_all_new_forward_event_rows( from_token, current_token, limit ) event_updates = ( (row[0], EventsStreamEventRow.TypeId, row[1:]) for row in event_rows ) - state_rows = yield self._store.get_all_updated_current_state_deltas( + state_rows = await self._store.get_all_updated_current_state_deltas( from_token, current_token, limit ) state_updates = ( |