1
1
from typing import (Any , TypeVar , Set , Dict , List , TextIO , Union , Tuple , Generic , Callable ,
2
2
Coroutine , Generator , Iterable , Awaitable , overload , Sequence , Iterator ,
3
3
Optional )
4
+ from types import FrameType
4
5
import concurrent .futures
5
6
from .events import AbstractEventLoop
6
7
from .futures import Future
@@ -15,9 +16,9 @@ _T4 = TypeVar('_T4')
15
16
_T5 = TypeVar ('_T5' )
16
17
_FutureT = Union [Future [_T ], Generator [Any , None , _T ], Awaitable [_T ]]
17
18
18
- FIRST_EXCEPTION = 'FIRST_EXCEPTION'
19
- FIRST_COMPLETED = 'FIRST_COMPLETED'
20
- ALL_COMPLETED = 'ALL_COMPLETED'
19
+ FIRST_EXCEPTION : str
20
+ FIRST_COMPLETED : str
21
+ ALL_COMPLETED : str
21
22
22
23
def as_completed (fs : Sequence [_FutureT [_T ]], * , loop : AbstractEventLoop = ...,
23
24
timeout : Optional [float ] = ...) -> Iterator [Generator [Any , None , _T ]]: ...
@@ -57,22 +58,13 @@ def wait_for(fut: _FutureT[_T], timeout: Optional[float],
57
58
* , loop : AbstractEventLoop = ...) -> Future [_T ]: ...
58
59
59
60
class Task (Future [_T ], Generic [_T ]):
60
- _all_tasks = ... # type: Set[Task]
61
- _current_tasks = ... # type: Dict[AbstractEventLoop, Task]
62
61
@classmethod
63
62
def current_task (cls , loop : AbstractEventLoop = ...) -> Task : ...
64
63
@classmethod
65
64
def all_tasks (cls , loop : AbstractEventLoop = ...) -> Set [Task ]: ...
66
-
67
- # Can't use a union, see mypy issue #1873.
68
- @overload
69
- def __init__ (self , coro : Generator [Any , None , _T ],
70
- * , loop : AbstractEventLoop = ...) -> None : ...
71
- @overload
72
- def __init__ (self , coro : Awaitable [_T ], * , loop : AbstractEventLoop = ...) -> None : ...
73
-
65
+ def __init__ (self , coro : Union [Generator [Any , None , _T ], Awaitable [_T ]], * , loop : AbstractEventLoop = ...) -> None : ...
74
66
def __repr__ (self ) -> str : ...
75
- def get_stack (self , * , limit : int = ...) -> List [Any ]: ... # return List[stackframe]
67
+ def get_stack (self , * , limit : int = ...) -> List [FrameType ]: ...
76
68
def print_stack (self , * , limit : int = ..., file : TextIO = ...) -> None : ...
77
69
def cancel (self ) -> bool : ...
78
70
def _step (self , value : Any = ..., exc : Exception = ...) -> None : ...
0 commit comments