|
1 | 1 | from _typeshed import Incomplete, Unused |
2 | | -from collections.abc import AsyncIterator, Awaitable, Callable, Iterable, Mapping, MutableMapping, Sequence |
| 2 | +from collections.abc import AsyncIterator, Awaitable, Callable, Generator, Iterable, Mapping, MutableMapping, Sequence |
3 | 3 | from datetime import datetime, timedelta |
4 | 4 | from types import TracebackType |
5 | 5 | from typing import Any, ClassVar, Generic, NoReturn, Protocol, overload |
@@ -67,7 +67,7 @@ class Redis(AbstractRedis, RedisModuleCommands, AsyncCoreCommands[_StrType], Asy |
67 | 67 | redis_connect_func: ConnectCallbackT | None = None, |
68 | 68 | credential_provider: CredentialProvider | None = None, |
69 | 69 | ) -> None: ... |
70 | | - def __await__(self): ... |
| 70 | + def __await__(self) -> Generator[Any, None, Self]: ... |
71 | 71 | async def initialize(self) -> Self: ... |
72 | 72 | def set_response_callback(self, command: str, callback: ResponseCallbackT): ... |
73 | 73 | def load_external_module(self, funcname, func) -> None: ... |
@@ -200,7 +200,7 @@ class Pipeline(Redis[_StrType], Generic[_StrType]): |
200 | 200 | async def __aexit__( |
201 | 201 | self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None |
202 | 202 | ) -> None: ... |
203 | | - def __await__(self): ... |
| 203 | + def __await__(self) -> Generator[Any, None, Self]: ... |
204 | 204 | def __len__(self) -> int: ... |
205 | 205 | def __bool__(self) -> bool: ... |
206 | 206 | async def reset(self) -> None: ... # type: ignore[override] |
|
0 commit comments