mirror of
https://github.com/davidhalter/typeshed.git
synced 2026-02-07 02:10:59 +08:00
Improve many __(a)exit__ annotations (#9696)
This commit is contained in:
@@ -1,6 +1,7 @@
|
||||
from _typeshed import Incomplete
|
||||
from _typeshed import Incomplete, Unused
|
||||
from collections.abc import AsyncIterator, Awaitable, Callable, Iterable, Mapping, MutableMapping, Sequence
|
||||
from datetime import datetime, timedelta
|
||||
from types import TracebackType
|
||||
from typing import Any, ClassVar, Generic, NoReturn, Protocol, overload
|
||||
from typing_extensions import Literal, Self, TypeAlias, TypedDict
|
||||
|
||||
@@ -93,7 +94,9 @@ class Redis(AbstractRedis, RedisModuleCommands, AsyncCoreCommands[_StrType], Asy
|
||||
def monitor(self) -> Monitor: ...
|
||||
def client(self) -> Redis[_StrType]: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, exc_type, exc_value, traceback) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __del__(self, _warnings: Any = ...) -> None: ...
|
||||
async def close(self, close_connection_pool: bool | None = ...) -> None: ...
|
||||
async def execute_command(self, *args, **options): ...
|
||||
@@ -117,7 +120,7 @@ class Monitor:
|
||||
def __init__(self, connection_pool: ConnectionPool) -> None: ...
|
||||
async def connect(self) -> None: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, *args) -> None: ...
|
||||
async def __aexit__(self, *args: Unused) -> None: ...
|
||||
async def next_command(self) -> MonitorCommandInfo: ...
|
||||
def listen(self) -> AsyncIterator[MonitorCommandInfo]: ...
|
||||
|
||||
@@ -143,7 +146,9 @@ class PubSub:
|
||||
encoder: Incomplete | None = ...,
|
||||
) -> None: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, exc_type, exc_value, traceback) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
async def reset(self) -> None: ...
|
||||
def close(self) -> Awaitable[NoReturn]: ...
|
||||
@@ -192,7 +197,9 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
|
||||
shard_hint: str | None,
|
||||
) -> None: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, exc_type, exc_value, traceback) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __await__(self): ...
|
||||
def __len__(self) -> int: ...
|
||||
def __bool__(self) -> bool: ...
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
from _typeshed import Incomplete
|
||||
from collections.abc import Awaitable, Callable, Mapping
|
||||
from types import TracebackType
|
||||
from typing import Any, Generic
|
||||
from typing_extensions import Self
|
||||
|
||||
@@ -76,7 +77,9 @@ class RedisCluster(AbstractRedis, AbstractRedisCluster, Generic[_StrType]): # T
|
||||
async def initialize(self) -> Self: ...
|
||||
async def close(self) -> None: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, exc_type: object, exc_value: object, traceback: object) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __await__(self) -> Awaitable[Self]: ...
|
||||
def __del__(self) -> None: ...
|
||||
async def on_connect(self, connection: Connection) -> None: ...
|
||||
@@ -146,10 +149,14 @@ class ClusterPipeline(AbstractRedis, AbstractRedisCluster, Generic[_StrType]):
|
||||
def __init__(self, client: RedisCluster[_StrType]) -> None: ...
|
||||
async def initialize(self) -> Self: ...
|
||||
async def __aenter__(self) -> Self: ...
|
||||
async def __aexit__(self, exc_type: object, exc_value: object, traceback: object) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __await__(self) -> Awaitable[Self]: ...
|
||||
def __enter__(self) -> Self: ...
|
||||
def __exit__(self, exc_type: object, exc_value: object, traceback: object) -> None: ...
|
||||
def __exit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __bool__(self) -> bool: ...
|
||||
def __len__(self) -> int: ...
|
||||
def execute_command(self, *args: KeyT | EncodableT, **kwargs: Any) -> Self: ...
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
from types import TracebackType
|
||||
from typing import Any, Generic
|
||||
|
||||
from redis.asyncio.client import Pipeline, Redis
|
||||
@@ -9,4 +10,6 @@ class pipeline(Generic[_StrType]):
|
||||
p: Pipeline[_StrType]
|
||||
def __init__(self, redis_obj: Redis[_StrType]) -> None: ...
|
||||
async def __aenter__(self) -> Pipeline[_StrType]: ...
|
||||
async def __aexit__(self, exc_type: object, exc_value: object, traceback: object) -> None: ...
|
||||
async def __aexit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
import threading
|
||||
from _typeshed import Incomplete, SupportsItems
|
||||
from _typeshed import Incomplete, SupportsItems, Unused
|
||||
from collections.abc import Callable, Iterable, Iterator, Mapping, Sequence
|
||||
from datetime import datetime, timedelta
|
||||
from re import Pattern
|
||||
@@ -314,7 +314,9 @@ class Redis(AbstractRedis, RedisModuleCommands, CoreCommands[_StrType], Sentinel
|
||||
def parse_response(self, connection, command_name, **options: _ParseResponseOptions): ...
|
||||
def monitor(self) -> Monitor: ...
|
||||
def __enter__(self) -> Redis[_StrType]: ...
|
||||
def __exit__(self, exc_type, exc_value, traceback): ...
|
||||
def __exit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
def close(self) -> None: ...
|
||||
def client(self) -> Redis[_StrType]: ...
|
||||
@@ -390,7 +392,9 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
|
||||
explicit_transaction: Any
|
||||
def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...
|
||||
def __enter__(self) -> Pipeline[_StrType]: ... # type: ignore[override]
|
||||
def __exit__(self, exc_type, exc_value, traceback) -> None: ...
|
||||
def __exit__(
|
||||
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
|
||||
) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
def __len__(self) -> int: ...
|
||||
def __bool__(self) -> bool: ...
|
||||
@@ -727,6 +731,6 @@ class Monitor:
|
||||
monitor_re: Pattern[str]
|
||||
def __init__(self, connection_pool) -> None: ...
|
||||
def __enter__(self) -> Self: ...
|
||||
def __exit__(self, *args: object) -> None: ...
|
||||
def __exit__(self, *args: Unused) -> None: ...
|
||||
def next_command(self) -> dict[str, Any]: ...
|
||||
def listen(self) -> Iterable[dict[str, Any]]: ...
|
||||
|
||||
Reference in New Issue
Block a user