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
|
"""
This namespace represents low-level functionality not intended for daily use,
but useful for extending Trio's functionality.
"""
import select as _select
import sys
import typing as _t
# This is the union of a subset of trio/_core/ and some things from trio/*.py.
# See comments in trio/__init__.py for details. To make static analysis easier,
# this lists all possible symbols from trio._core, and then we prune those that
# aren't available on this system. After that we add some symbols from trio/*.py.
# Generally available symbols
from ._core import (
cancel_shielded_checkpoint,
Abort,
wait_task_rescheduled,
enable_ki_protection,
disable_ki_protection,
currently_ki_protected,
Task,
checkpoint,
current_task,
ParkingLot,
UnboundedQueue,
RunVar,
TrioToken,
current_trio_token,
temporarily_detach_coroutine_object,
permanently_detach_coroutine_object,
reattach_detached_coroutine_object,
current_statistics,
reschedule,
remove_instrument,
add_instrument,
current_clock,
current_root_task,
checkpoint_if_cancelled,
spawn_system_task,
wait_readable,
wait_writable,
notify_closing,
start_thread_soon,
start_guest_run,
)
from ._subprocess import open_process
if sys.platform == "win32":
# Windows symbols
from ._core import (
current_iocp,
register_with_iocp,
wait_overlapped,
monitor_completion_key,
readinto_overlapped,
write_overlapped,
)
from ._wait_for_object import WaitForSingleObject
else:
# Unix symbols
from ._unix_pipes import FdStream
# Kqueue-specific symbols
if sys.platform != "linux" and (_t.TYPE_CHECKING or not hasattr(_select, "epoll")):
from ._core import (
current_kqueue,
monitor_kevent,
wait_kevent,
)
del sys
|
