Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/anyio/__init__.py: 100%

1from __future__ import annotations 

2 

3from typing import TYPE_CHECKING 

4 

5from ._lazyimport import ( 

6 fix_package_names, 

7 install_lazy_importer, 

8 set_deprecated_aliases, 

9) 

10 

11if TYPE_CHECKING or not install_lazy_importer(): 

12 from ._core._concurrency_utils import amap as amap 

13 from ._core._concurrency_utils import as_completed as as_completed 

14 from ._core._concurrency_utils import gather as gather 

15 from ._core._contextmanagers import ( 

16 AsyncContextManagerMixin as AsyncContextManagerMixin, 

17 ) 

18 from ._core._contextmanagers import ContextManagerMixin as ContextManagerMixin 

19 from ._core._eventloop import current_time as current_time 

20 from ._core._eventloop import get_all_backends as get_all_backends 

21 from ._core._eventloop import get_available_backends as get_available_backends 

22 from ._core._eventloop import get_cancelled_exc_class as get_cancelled_exc_class 

23 from ._core._eventloop import run as run 

24 from ._core._eventloop import sleep as sleep 

25 from ._core._eventloop import sleep_forever as sleep_forever 

26 from ._core._eventloop import sleep_until as sleep_until 

27 from ._core._exceptions import BrokenResourceError as BrokenResourceError 

28 from ._core._exceptions import BrokenWorkerInterpreter as BrokenWorkerInterpreter 

29 from ._core._exceptions import BrokenWorkerProcess as BrokenWorkerProcess 

30 from ._core._exceptions import BusyResourceError as BusyResourceError 

31 from ._core._exceptions import ClosedResourceError as ClosedResourceError 

32 from ._core._exceptions import ConnectionFailed as ConnectionFailed 

33 from ._core._exceptions import DelimiterNotFound as DelimiterNotFound 

34 from ._core._exceptions import EndOfStream as EndOfStream 

35 from ._core._exceptions import FutureAlreadyFinished as FutureAlreadyFinished 

36 from ._core._exceptions import FutureCancelled as FutureCancelled 

37 from ._core._exceptions import FutureFailed as FutureFailed 

38 from ._core._exceptions import FutureNotFinished as FutureNotFinished 

39 from ._core._exceptions import IncompleteRead as IncompleteRead 

40 from ._core._exceptions import NoEventLoopError as NoEventLoopError 

41 from ._core._exceptions import RunFinishedError as RunFinishedError 

42 from ._core._exceptions import TaskCancelled as TaskCancelled 

43 from ._core._exceptions import TaskFailed as TaskFailed 

44 from ._core._exceptions import TaskNotFinished as TaskNotFinished 

45 from ._core._exceptions import ( 

46 TypedAttributeLookupError as TypedAttributeLookupError, 

47 ) 

48 from ._core._exceptions import WouldBlock as WouldBlock 

49 from ._core._fileio import AsyncFile as AsyncFile 

50 from ._core._fileio import Path as Path 

51 from ._core._fileio import open_file as open_file 

52 from ._core._fileio import wrap_file as wrap_file 

53 from ._core._futures import Future as Future 

54 from ._core._resources import aclose_forcefully as aclose_forcefully 

55 from ._core._signals import open_signal_receiver as open_signal_receiver 

56 from ._core._sockets import TCPConnectable as TCPConnectable 

57 from ._core._sockets import UNIXConnectable as UNIXConnectable 

58 from ._core._sockets import as_connectable as as_connectable 

59 from ._core._sockets import connect_tcp as connect_tcp 

60 from ._core._sockets import connect_unix as connect_unix 

61 from ._core._sockets import ( 

62 create_connected_udp_socket as create_connected_udp_socket, 

63 ) 

64 from ._core._sockets import ( 

65 create_connected_unix_datagram_socket as create_connected_unix_datagram_socket, 

66 ) 

67 from ._core._sockets import create_tcp_listener as create_tcp_listener 

68 from ._core._sockets import create_udp_socket as create_udp_socket 

69 from ._core._sockets import ( 

70 create_unix_datagram_socket as create_unix_datagram_socket, 

71 ) 

72 from ._core._sockets import create_unix_listener as create_unix_listener 

73 from ._core._sockets import getaddrinfo as getaddrinfo 

74 from ._core._sockets import getnameinfo as getnameinfo 

75 from ._core._sockets import notify_closing as notify_closing 

76 from ._core._sockets import wait_readable as wait_readable 

77 from ._core._sockets import wait_socket_readable as wait_socket_readable 

78 from ._core._sockets import wait_socket_writable as wait_socket_writable 

79 from ._core._sockets import wait_writable as wait_writable 

80 from ._core._streams import ( 

81 create_memory_object_stream as create_memory_object_stream, 

82 ) 

83 from ._core._subprocesses import open_process as open_process 

84 from ._core._subprocesses import run_process as run_process 

85 from ._core._synchronization import CapacityLimiter as CapacityLimiter 

86 from ._core._synchronization import ( 

87 CapacityLimiterStatistics as CapacityLimiterStatistics, 

88 ) 

89 from ._core._synchronization import Condition as Condition 

90 from ._core._synchronization import ConditionStatistics as ConditionStatistics 

91 from ._core._synchronization import Event as Event 

92 from ._core._synchronization import EventStatistics as EventStatistics 

93 from ._core._synchronization import Lock as Lock 

94 from ._core._synchronization import LockStatistics as LockStatistics 

95 from ._core._synchronization import ResourceGuard as ResourceGuard 

96 from ._core._synchronization import Semaphore as Semaphore 

97 from ._core._synchronization import SemaphoreStatistics as SemaphoreStatistics 

98 from ._core._tasks import TASK_STATUS_IGNORED as TASK_STATUS_IGNORED 

99 from ._core._tasks import CancelScope as CancelScope 

100 from ._core._tasks import TaskHandle as TaskHandle 

101 from ._core._tasks import create_task_group as create_task_group 

102 from ._core._tasks import current_effective_deadline as current_effective_deadline 

103 from ._core._tasks import fail_after as fail_after 

104 from ._core._tasks import fail_at as fail_at 

105 from ._core._tasks import move_on_after as move_on_after 

106 from ._core._tasks import move_on_at as move_on_at 

107 from ._core._tempfile import NamedTemporaryFile as NamedTemporaryFile 

108 from ._core._tempfile import SpooledTemporaryFile as SpooledTemporaryFile 

109 from ._core._tempfile import TemporaryDirectory as TemporaryDirectory 

110 from ._core._tempfile import TemporaryFile as TemporaryFile 

111 from ._core._tempfile import gettempdir as gettempdir 

112 from ._core._tempfile import gettempdirb as gettempdirb 

113 from ._core._tempfile import mkdtemp as mkdtemp 

114 from ._core._tempfile import mkstemp as mkstemp 

115 from ._core._testing import TaskInfo as TaskInfo 

116 from ._core._testing import get_current_task as get_current_task 

117 from ._core._testing import get_running_tasks as get_running_tasks 

118 from ._core._testing import wait_all_tasks_blocked as wait_all_tasks_blocked 

119 from ._core._typedattr import TypedAttributeProvider as TypedAttributeProvider 

120 from ._core._typedattr import TypedAttributeSet as TypedAttributeSet 

121 from ._core._typedattr import typed_attribute as typed_attribute 

122 

123 # ruff: isort: off 

124 from . import ( 

125 abc as abc, 

126 ) 

127 from . import ( 

128 from_thread as from_thread, 

129 ) 

130 from . import ( 

131 functools as functools, 

132 ) 

133 from . import ( 

134 itertools as itertools, 

135 ) 

136 from . import ( 

137 lowlevel as lowlevel, 

138 ) 

139 from . import ( 

140 to_interpreter as to_interpreter, 

141 ) 

142 from . import ( 

143 to_process as to_process, 

144 ) 

145 from . import ( 

146 to_thread as to_thread, 

147 ) 

148 

149 fix_package_names() 

150 set_deprecated_aliases( 

151 { 

152 "BrokenWorkerIntepreter": "anyio.BrokenWorkerInterpreter", 

153 } 

154 )