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/handlers/initial_sync.py | |
| parent | re-implement daemonize (#8011) (diff) | |
| download | synapse-e19de43eb5903c3b6ccca82334971ebc57fc38de.tar.xz | |
Convert streams to async. (#8014)
Diffstat (limited to 'synapse/handlers/initial_sync.py')
| -rw-r--r-- | synapse/handlers/initial_sync.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/initial_sync.py b/synapse/handlers/initial_sync.py index f88bad5f25..ae6bd1d352 100644 --- a/synapse/handlers/initial_sync.py +++ b/synapse/handlers/initial_sync.py @@ -109,7 +109,7 @@ class InitialSyncHandler(BaseHandler): rooms_ret = [] - now_token = await self.hs.get_event_sources().get_current_token() + now_token = self.hs.get_event_sources().get_current_token() presence_stream = self.hs.get_event_sources().sources["presence"] pagination_config = PaginationConfig(from_token=now_token) @@ -360,7 +360,7 @@ class InitialSyncHandler(BaseHandler): current_state.values(), time_now ) - now_token = await self.hs.get_event_sources().get_current_token() + now_token = self.hs.get_event_sources().get_current_token() limit = pagin_config.limit if pagin_config else None if limit is None: |