diff options
author | Sean Quah <8349537+squahtx@users.noreply.github.com> | 2021-12-14 17:35:28 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-12-14 17:35:28 +0000 |
commit | 0147b3de20f313975226a9a3f319c77b90aa2793 (patch) | |
tree | 7dfe4b6dd7832999241defb5cbf06894f9f1342d /synapse/http/federation | |
parent | Add missing type hints to `synapse.appservice` (#11360) (diff) | |
download | synapse-0147b3de20f313975226a9a3f319c77b90aa2793.tar.xz |
Add missing type hints to `synapse.logging.context` (#11556)
Diffstat (limited to 'synapse/http/federation')
-rw-r--r-- | synapse/http/federation/matrix_federation_agent.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/synapse/http/federation/matrix_federation_agent.py b/synapse/http/federation/matrix_federation_agent.py index 1238bfd287..a8a520f809 100644 --- a/synapse/http/federation/matrix_federation_agent.py +++ b/synapse/http/federation/matrix_federation_agent.py @@ -25,6 +25,7 @@ from zope.interface import implementer from twisted.internet import defer from twisted.internet.endpoints import HostnameEndpoint, wrapClientTLS from twisted.internet.interfaces import ( + IProtocol, IProtocolFactory, IReactorCore, IStreamClientEndpoint, @@ -309,12 +310,14 @@ class MatrixHostnameEndpoint: self._srv_resolver = srv_resolver - def connect(self, protocol_factory: IProtocolFactory) -> defer.Deferred: + def connect( + self, protocol_factory: IProtocolFactory + ) -> "defer.Deferred[IProtocol]": """Implements IStreamClientEndpoint interface""" return run_in_background(self._do_connect, protocol_factory) - async def _do_connect(self, protocol_factory: IProtocolFactory) -> None: + async def _do_connect(self, protocol_factory: IProtocolFactory) -> IProtocol: first_exception = None server_list = await self._resolve_server() |