@@ -7,7 +7,7 @@ from _asyncio import (
7
7
_register_task as _register_task ,
8
8
_unregister_task as _unregister_task ,
9
9
)
10
- from collections .abc import Awaitable , Coroutine , Generator , Iterable , Iterator
10
+ from collections .abc import AsyncIterator , Awaitable , Coroutine , Generator , Iterable , Iterator
11
11
from typing import Any , Literal , Protocol , TypeVar , overload
12
12
from typing_extensions import TypeAlias
13
13
@@ -84,7 +84,12 @@ FIRST_COMPLETED = concurrent.futures.FIRST_COMPLETED
84
84
FIRST_EXCEPTION = concurrent .futures .FIRST_EXCEPTION
85
85
ALL_COMPLETED = concurrent .futures .ALL_COMPLETED
86
86
87
- if sys .version_info >= (3 , 10 ):
87
+ if sys .version_info >= (3 , 13 ):
88
+ class _SyncAndAsyncIterator (Iterator [_T_co ], AsyncIterator [_T_co ], Protocol [_T_co ]): ...
89
+
90
+ def as_completed (fs : Iterable [_FutureLike [_T ]], * , timeout : float | None = None ) -> _SyncAndAsyncIterator [Future [_T ]]: ...
91
+
92
+ elif sys .version_info >= (3 , 10 ):
88
93
def as_completed (fs : Iterable [_FutureLike [_T ]], * , timeout : float | None = None ) -> Iterator [Future [_T ]]: ...
89
94
90
95
else :
0 commit comments