1
0

Broaden type hints; update comment

This commit is contained in:
Andrew Morgan
2021-11-19 18:17:14 +00:00
parent ce020c30fc
commit 8f1183cf7b
2 changed files with 7 additions and 5 deletions

View File

@@ -48,7 +48,7 @@ This is all tied together by the AppServiceScheduler which DIs the required
components.
"""
import logging
from typing import List, Optional
from typing import Iterable, List, Optional
from synapse.appservice import ApplicationService, ApplicationServiceState
from synapse.events import EventBase
@@ -95,8 +95,8 @@ 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)
@@ -130,7 +130,9 @@ class _ServiceQueuer:
self.queued_events.setdefault(service.id, []).append(event)
self._start_background_request(service)
def enqueue_ephemeral(self, service: ApplicationService, events: List[JsonDict]):
def enqueue_ephemeral(
self, service: ApplicationService, events: Iterable[JsonDict]
) -> None:
self.queued_ephemeral.setdefault(service.id, []).extend(events)
self._start_background_request(service)

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: