Rooba
/
uvloop
mirror of https://github.com/MagicStack/uvloop.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

_TransProtPair is no longer defined in asyncio.events

This commit is contained in:
Jens Jorgensen 2022-06-21 17:02:15 -05:00 committed by Fantix King
parent 3e71ddc338
commit fae5f7fb78
No known key found for this signature in database
GPG Key ID: 95304B04071CCDB4
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
uvloop/loop.pyi
View File

@ -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,