File size: 4,073 Bytes
4a51346
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
from __future__ import annotations

__all__ = (
    "maybe_async",
    "maybe_async_cm",
    "run",
    "sleep",
    "sleep_forever",
    "sleep_until",
    "current_time",
    "get_all_backends",
    "get_cancelled_exc_class",
    "BrokenResourceError",
    "BrokenWorkerProcess",
    "BusyResourceError",
    "ClosedResourceError",
    "DelimiterNotFound",
    "EndOfStream",
    "ExceptionGroup",
    "IncompleteRead",
    "TypedAttributeLookupError",
    "WouldBlock",
    "AsyncFile",
    "Path",
    "open_file",
    "wrap_file",
    "aclose_forcefully",
    "open_signal_receiver",
    "connect_tcp",
    "connect_unix",
    "create_tcp_listener",
    "create_unix_listener",
    "create_udp_socket",
    "create_connected_udp_socket",
    "getaddrinfo",
    "getnameinfo",
    "wait_socket_readable",
    "wait_socket_writable",
    "create_memory_object_stream",
    "run_process",
    "open_process",
    "create_lock",
    "CapacityLimiter",
    "CapacityLimiterStatistics",
    "Condition",
    "ConditionStatistics",
    "Event",
    "EventStatistics",
    "Lock",
    "LockStatistics",
    "Semaphore",
    "SemaphoreStatistics",
    "create_condition",
    "create_event",
    "create_semaphore",
    "create_capacity_limiter",
    "open_cancel_scope",
    "fail_after",
    "move_on_after",
    "current_effective_deadline",
    "TASK_STATUS_IGNORED",
    "CancelScope",
    "create_task_group",
    "TaskInfo",
    "get_current_task",
    "get_running_tasks",
    "wait_all_tasks_blocked",
    "run_sync_in_worker_thread",
    "run_async_from_thread",
    "run_sync_from_thread",
    "current_default_worker_thread_limiter",
    "create_blocking_portal",
    "start_blocking_portal",
    "typed_attribute",
    "TypedAttributeSet",
    "TypedAttributeProvider",
)

from typing import Any

from ._core._compat import maybe_async, maybe_async_cm
from ._core._eventloop import (
    current_time,
    get_all_backends,
    get_cancelled_exc_class,
    run,
    sleep,
    sleep_forever,
    sleep_until,
)
from ._core._exceptions import (
    BrokenResourceError,
    BrokenWorkerProcess,
    BusyResourceError,
    ClosedResourceError,
    DelimiterNotFound,
    EndOfStream,
    ExceptionGroup,
    IncompleteRead,
    TypedAttributeLookupError,
    WouldBlock,
)
from ._core._fileio import AsyncFile, Path, open_file, wrap_file
from ._core._resources import aclose_forcefully
from ._core._signals import open_signal_receiver
from ._core._sockets import (
    connect_tcp,
    connect_unix,
    create_connected_udp_socket,
    create_tcp_listener,
    create_udp_socket,
    create_unix_listener,
    getaddrinfo,
    getnameinfo,
    wait_socket_readable,
    wait_socket_writable,
)
from ._core._streams import create_memory_object_stream
from ._core._subprocesses import open_process, run_process
from ._core._synchronization import (
    CapacityLimiter,
    CapacityLimiterStatistics,
    Condition,
    ConditionStatistics,
    Event,
    EventStatistics,
    Lock,
    LockStatistics,
    Semaphore,
    SemaphoreStatistics,
    create_capacity_limiter,
    create_condition,
    create_event,
    create_lock,
    create_semaphore,
)
from ._core._tasks import (
    TASK_STATUS_IGNORED,
    CancelScope,
    create_task_group,
    current_effective_deadline,
    fail_after,
    move_on_after,
    open_cancel_scope,
)
from ._core._testing import (
    TaskInfo,
    get_current_task,
    get_running_tasks,
    wait_all_tasks_blocked,
)
from ._core._typedattr import TypedAttributeProvider, TypedAttributeSet, typed_attribute

# Re-exported here, for backwards compatibility
# isort: off
from .to_thread import current_default_worker_thread_limiter, run_sync_in_worker_thread
from .from_thread import (
    create_blocking_portal,
    run_async_from_thread,
    run_sync_from_thread,
    start_blocking_portal,
)

# Re-export imports so they look like they live directly in this package
key: str
value: Any
for key, value in list(locals().items()):
    if getattr(value, "__module__", "").startswith("anyio."):
        value.__module__ = __name__