diff options
author | Patrick Cloke <clokep@users.noreply.github.com> | 2021-09-21 13:34:26 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-09-21 13:34:26 -0400 |
commit | 4054dfa409fa17b45ab8f265813994956ed97bae (patch) | |
tree | 8a2c2a5700dcd62f1b8ad8593d0b25c9c7b32e55 /synapse/handlers/appservice.py | |
parent | Add types to http.site (#10867) (diff) | |
download | synapse-4054dfa409fa17b45ab8f265813994956ed97bae.tar.xz |
Add type hints for event streams. (#10856)
Diffstat (limited to 'synapse/handlers/appservice.py')
-rw-r--r-- | synapse/handlers/appservice.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py index 8bde9ed66f..b7213b67a5 100644 --- a/synapse/handlers/appservice.py +++ b/synapse/handlers/appservice.py @@ -254,7 +254,7 @@ class ApplicationServicesHandler: async def _handle_typing( self, service: ApplicationService, new_token: int ) -> List[JsonDict]: - typing_source = self.event_sources.sources["typing"] + typing_source = self.event_sources.sources.typing # Get the typing events from just before current typing, _ = await typing_source.get_new_events_as( service=service, @@ -269,7 +269,7 @@ class ApplicationServicesHandler: from_key = await self.store.get_type_stream_id_for_appservice( service, "read_receipt" ) - receipts_source = self.event_sources.sources["receipt"] + receipts_source = self.event_sources.sources.receipt receipts, _ = await receipts_source.get_new_events_as( service=service, from_key=from_key ) @@ -279,7 +279,7 @@ class ApplicationServicesHandler: self, service: ApplicationService, users: Collection[Union[str, UserID]] ) -> List[JsonDict]: events: List[JsonDict] = [] - presence_source = self.event_sources.sources["presence"] + presence_source = self.event_sources.sources.presence from_key = await self.store.get_type_stream_id_for_appservice( service, "presence" ) |