Skip to content

Commit

Permalink
_TransProtPair is no longer defined in asyncio.events
Browse files Browse the repository at this point in the history
  • Loading branch information
jensbjorgensen authored and fantix committed Jul 16, 2022
1 parent 3e71ddc commit fae5f7f
Showing 1 changed file with 10 additions and 9 deletions.
19 changes: 10 additions & 9 deletions uvloop/loop.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down Expand Up @@ -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,
Expand All @@ -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,
Expand All @@ -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: ...
Expand All @@ -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: ...
Expand All @@ -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,
Expand All @@ -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: ...
Expand All @@ -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,
Expand Down

0 comments on commit fae5f7f

Please sign in to comment.