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

1from __future__ import annotations 

2 

3__all__ = ( 

4 "maybe_async", 

5 "maybe_async_cm", 

6 "run", 

7 "sleep", 

8 "sleep_forever", 

9 "sleep_until", 

10 "current_time", 

11 "get_all_backends", 

12 "get_cancelled_exc_class", 

13 "BrokenResourceError", 

14 "BrokenWorkerProcess", 

15 "BusyResourceError", 

16 "ClosedResourceError", 

17 "DelimiterNotFound", 

18 "EndOfStream", 

19 "ExceptionGroup", 

20 "IncompleteRead", 

21 "TypedAttributeLookupError", 

22 "WouldBlock", 

23 "AsyncFile", 

24 "Path", 

25 "open_file", 

26 "wrap_file", 

27 "aclose_forcefully", 

28 "open_signal_receiver", 

29 "connect_tcp", 

30 "connect_unix", 

31 "create_tcp_listener", 

32 "create_unix_listener", 

33 "create_udp_socket", 

34 "create_connected_udp_socket", 

35 "getaddrinfo", 

36 "getnameinfo", 

37 "wait_socket_readable", 

38 "wait_socket_writable", 

39 "create_memory_object_stream", 

40 "run_process", 

41 "open_process", 

42 "create_lock", 

43 "CapacityLimiter", 

44 "CapacityLimiterStatistics", 

45 "Condition", 

46 "ConditionStatistics", 

47 "Event", 

48 "EventStatistics", 

49 "Lock", 

50 "LockStatistics", 

51 "Semaphore", 

52 "SemaphoreStatistics", 

53 "create_condition", 

54 "create_event", 

55 "create_semaphore", 

56 "create_capacity_limiter", 

57 "open_cancel_scope", 

58 "fail_after", 

59 "move_on_after", 

60 "current_effective_deadline", 

61 "TASK_STATUS_IGNORED", 

62 "CancelScope", 

63 "create_task_group", 

64 "TaskInfo", 

65 "get_current_task", 

66 "get_running_tasks", 

67 "wait_all_tasks_blocked", 

68 "run_sync_in_worker_thread", 

69 "run_async_from_thread", 

70 "run_sync_from_thread", 

71 "current_default_worker_thread_limiter", 

72 "create_blocking_portal", 

73 "start_blocking_portal", 

74 "typed_attribute", 

75 "TypedAttributeSet", 

76 "TypedAttributeProvider", 

77) 

78 

79from typing import Any 

80 

81from ._core._compat import maybe_async, maybe_async_cm 

82from ._core._eventloop import ( 

83 current_time, 

84 get_all_backends, 

85 get_cancelled_exc_class, 

86 run, 

87 sleep, 

88 sleep_forever, 

89 sleep_until, 

90) 

91from ._core._exceptions import ( 

92 BrokenResourceError, 

93 BrokenWorkerProcess, 

94 BusyResourceError, 

95 ClosedResourceError, 

96 DelimiterNotFound, 

97 EndOfStream, 

98 ExceptionGroup, 

99 IncompleteRead, 

100 TypedAttributeLookupError, 

101 WouldBlock, 

102) 

103from ._core._fileio import AsyncFile, Path, open_file, wrap_file 

104from ._core._resources import aclose_forcefully 

105from ._core._signals import open_signal_receiver 

106from ._core._sockets import ( 

107 connect_tcp, 

108 connect_unix, 

109 create_connected_udp_socket, 

110 create_tcp_listener, 

111 create_udp_socket, 

112 create_unix_listener, 

113 getaddrinfo, 

114 getnameinfo, 

115 wait_socket_readable, 

116 wait_socket_writable, 

117) 

118from ._core._streams import create_memory_object_stream 

119from ._core._subprocesses import open_process, run_process 

120from ._core._synchronization import ( 

121 CapacityLimiter, 

122 CapacityLimiterStatistics, 

123 Condition, 

124 ConditionStatistics, 

125 Event, 

126 EventStatistics, 

127 Lock, 

128 LockStatistics, 

129 Semaphore, 

130 SemaphoreStatistics, 

131 create_capacity_limiter, 

132 create_condition, 

133 create_event, 

134 create_lock, 

135 create_semaphore, 

136) 

137from ._core._tasks import ( 

138 TASK_STATUS_IGNORED, 

139 CancelScope, 

140 create_task_group, 

141 current_effective_deadline, 

142 fail_after, 

143 move_on_after, 

144 open_cancel_scope, 

145) 

146from ._core._testing import ( 

147 TaskInfo, 

148 get_current_task, 

149 get_running_tasks, 

150 wait_all_tasks_blocked, 

151) 

152from ._core._typedattr import TypedAttributeProvider, TypedAttributeSet, typed_attribute 

153 

154# Re-exported here, for backwards compatibility 

155# isort: off 

156from .to_thread import current_default_worker_thread_limiter, run_sync_in_worker_thread 

157from .from_thread import ( 

158 create_blocking_portal, 

159 run_async_from_thread, 

160 run_sync_from_thread, 

161 start_blocking_portal, 

162) 

163 

164# Re-export imports so they look like they live directly in this package 

165key: str 

166value: Any 

167for key, value in list(locals().items()): 

168 if getattr(value, "__module__", "").startswith("anyio."): 

169 value.__module__ = __name__