kaslo/synapse
1
0
Fork 0
Code Wiki Activity

Broaden type hints; update comment

Browse Source
This commit is contained in:
Andrew Morgan
2021-11-19 18:17:14 +00:00
committed by Olivier Wilkinson (reivilibre)
parent 0fe753cc7f
commit edfb4f5e9f
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
synapse/appservice/scheduler.py
View File

@@ -103,7 +103,7 @@ class ApplicationServiceScheduler:
self.queuer.enqueue_event(service, event)
def submit_ephemeral_events_for_as(
self, service: ApplicationService, events: List[JsonDict]
self, service: ApplicationService, events: Iterable[JsonDict]
) -> None:
self.queuer.enqueue_ephemeral(service, events)
@@ -141,7 +141,7 @@ class _ServiceQueuer:
self._start_background_request(service)
def enqueue_ephemeral(
self, service: ApplicationService, events: List[JsonDict]
self, service: ApplicationService, events: Iterable[JsonDict]
) -> None:
self.queued_ephemeral.setdefault(service.id, []).extend(events)
self._start_background_request(service)

2
synapse/handlers/appservice.py
View File

@@ -325,7 +325,7 @@ class ApplicationServicesHandler:
)
elif stream_key == "to_device_key":
# Retrieve an iterable of to-device message events, as well as the
# Retrieve a list of to-device message events, as well as the
# maximum stream token of the messages we were able to retrieve.
events = await self._handle_to_device(service, new_token, users)
if events: