1 from typing import Any
\r
2 from collections import namedtuple
\r
4 singledispatch = ... # type: Any
\r
6 class KeyReuseError(Exception): ...
\r
7 class UnknownKeyError(Exception): ...
\r
8 class LeakedCallbackError(Exception): ...
\r
9 class BadYieldError(Exception): ...
\r
10 class ReturnValueIgnoredError(Exception): ...
\r
11 class TimeoutError(Exception): ...
\r
13 def engine(func): ...
\r
14 def coroutine(func, replace_callback=...): ...
\r
16 class Return(Exception):
\r
17 value = ... # type: Any
\r
18 def __init__(self, value=...) -> None: ...
\r
21 current_index = ... # type: Any
\r
22 def __init__(self, *args, **kwargs) -> None: ...
\r
27 def start(self, runner): ...
\r
28 def is_ready(self): ...
\r
29 def get_result(self): ...
\r
31 class Callback(YieldPoint):
\r
32 key = ... # type: Any
\r
33 def __init__(self, key) -> None: ...
\r
34 runner = ... # type: Any
\r
35 def start(self, runner): ...
\r
36 def is_ready(self): ...
\r
37 def get_result(self): ...
\r
39 class Wait(YieldPoint):
\r
40 key = ... # type: Any
\r
41 def __init__(self, key) -> None: ...
\r
42 runner = ... # type: Any
\r
43 def start(self, runner): ...
\r
44 def is_ready(self): ...
\r
45 def get_result(self): ...
\r
47 class WaitAll(YieldPoint):
\r
48 keys = ... # type: Any
\r
49 def __init__(self, keys) -> None: ...
\r
50 runner = ... # type: Any
\r
51 def start(self, runner): ...
\r
52 def is_ready(self): ...
\r
53 def get_result(self): ...
\r
55 def Task(func, *args, **kwargs): ...
\r
57 class YieldFuture(YieldPoint):
\r
58 future = ... # type: Any
\r
59 io_loop = ... # type: Any
\r
60 def __init__(self, future, io_loop=...) -> None: ...
\r
61 runner = ... # type: Any
\r
62 key = ... # type: Any
\r
63 result_fn = ... # type: Any
\r
64 def start(self, runner): ...
\r
65 def is_ready(self): ...
\r
66 def get_result(self): ...
\r
68 class Multi(YieldPoint):
\r
69 keys = ... # type: Any
\r
70 children = ... # type: Any
\r
71 unfinished_children = ... # type: Any
\r
72 quiet_exceptions = ... # type: Any
\r
73 def __init__(self, children, quiet_exceptions=...) -> None: ...
\r
74 def start(self, runner): ...
\r
75 def is_ready(self): ...
\r
76 def get_result(self): ...
\r
78 def multi_future(children, quiet_exceptions=...): ...
\r
79 def maybe_future(x): ...
\r
80 def with_timeout(timeout, future, io_loop=..., quiet_exceptions=...): ...
\r
81 def sleep(duration): ...
\r
83 moment = ... # type: Any
\r
86 gen = ... # type: Any
\r
87 result_future = ... # type: Any
\r
88 future = ... # type: Any
\r
89 yield_point = ... # type: Any
\r
90 pending_callbacks = ... # type: Any
\r
91 results = ... # type: Any
\r
92 running = ... # type: Any
\r
93 finished = ... # type: Any
\r
94 had_exception = ... # type: Any
\r
95 io_loop = ... # type: Any
\r
96 stack_context_deactivate = ... # type: Any
\r
97 def __init__(self, gen, result_future, first_yielded) -> None: ...
\r
98 def register_callback(self, key): ...
\r
99 def is_ready(self, key): ...
\r
100 def set_result(self, key, result): ...
\r
101 def pop_result(self, key): ...
\r
103 def handle_yield(self, yielded): ...
\r
104 def result_callback(self, key): ...
\r
105 def handle_exception(self, typ, value, tb): ...
\r
107 Arguments = namedtuple('Arguments', ['args', 'kwargs'])
\r
109 def convert_yielded(yielded): ...
\r