diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-08-04 07:21:47 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-04 07:21:47 -0400 |
| commit | e19de43eb5903c3b6ccca82334971ebc57fc38de (patch) | |
| tree | 5925175ac5a8c43303bc5e262fc9bd4f2d6e76f3 /synapse/notifier.py | |
| parent | re-implement daemonize (#8011) (diff) | |
| download | synapse-e19de43eb5903c3b6ccca82334971ebc57fc38de.tar.xz | |
Convert streams to async. (#8014)
Diffstat (limited to 'synapse/notifier.py')
| -rw-r--r-- | synapse/notifier.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index bd41f77852..22ab4a9da5 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -320,7 +320,7 @@ class Notifier(object): """ user_stream = self.user_to_user_stream.get(user_id) if user_stream is None: - current_token = await self.event_sources.get_current_token() + current_token = self.event_sources.get_current_token() if room_ids is None: room_ids = await self.store.get_rooms_for_user(user_id) user_stream = _NotifierUserStream( @@ -397,7 +397,7 @@ class Notifier(object): """ from_token = pagination_config.from_token if not from_token: - from_token = await self.event_sources.get_current_token() + from_token = self.event_sources.get_current_token() limit = pagination_config.limit |