_TransProtPair is no longer defined in asyncio.events

Author: jensbjorgensen

uvloop/loop.pyi

@@ -21,6 +21,7 @@ _T = TypeVar('_T')
 _Context = Dict[str, Any]
 _ExceptionHandler = Callable[[asyncio.AbstractEventLoop, _Context], Any]
 _SSLContext = Union[bool, None, ssl.SSLContext]
+_TransProtPair = Tuple[asyncio.transports.BaseTransport, asyncio.protocols.BaseProtocol]
 
 class Loop:
     def call_soon(
@@ -155,7 +156,7 @@ class Loop:
         server_hostname: Optional[str] = ...,
         ssl_handshake_timeout: Optional[float] = ...,
         ssl_shutdown_timeout: Optional[float] = ...,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     @overload
     async def create_connection(
         self,
@@ -172,7 +173,7 @@ class Loop:
         server_hostname: Optional[str] = ...,
         ssl_handshake_timeout: Optional[float] = ...,
         ssl_shutdown_timeout: Optional[float] = ...,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def create_unix_server(
         self,
         protocol_factory: asyncio.events._ProtocolFactory,
@@ -195,7 +196,7 @@ class Loop:
         server_hostname: Optional[str] = ...,
         ssl_handshake_timeout: Optional[float] = ...,
         ssl_shutdown_timeout: Optional[float] = ...,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     def default_exception_handler(self, context: _Context) -> None: ...
     def get_exception_handler(self) -> Optional[_ExceptionHandler]: ...
     def set_exception_handler(self, handler: Optional[_ExceptionHandler]) -> None: ...
@@ -217,7 +218,7 @@ class Loop:
         ssl: _SSLContext = ...,
         ssl_handshake_timeout: Optional[float] = ...,
         ssl_shutdown_timeout: Optional[float] = ...,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def run_in_executor(
         self, executor: Any, func: Callable[..., _T], *args: Any
     ) -> _T: ...
@@ -231,7 +232,7 @@ class Loop:
         stdout: Any = ...,
         stderr: Any = ...,
         **kwargs: Any,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def subprocess_exec(
         self,
         protocol_factory: asyncio.events._ProtocolFactory,
@@ -240,13 +241,13 @@ class Loop:
         stdout: Any = ...,
         stderr: Any = ...,
         **kwargs: Any,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def connect_read_pipe(
         self, protocol_factory: asyncio.events._ProtocolFactory, pipe: Any
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def connect_write_pipe(
         self, protocol_factory: asyncio.events._ProtocolFactory, pipe: Any
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     def add_signal_handler(
         self, sig: int, callback: Callable[..., Any], *args: Any
     ) -> None: ...
@@ -264,7 +265,7 @@ class Loop:
         reuse_port: Optional[bool] = ...,
         allow_broadcast: Optional[bool] = ...,
         sock: Optional[socket] = ...,
-    ) -> asyncio.events._TransProtPair: ...
+    ) -> _TransProtPair: ...
     async def shutdown_asyncgens(self) -> None: ...
     async def shutdown_default_executor(self) -> None: ...
     # Loop doesn't implement these, but since they are marked as abstract in typeshed,