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

1from __future__ import annotations 

2 

3from ._core._contextmanagers import AsyncContextManagerMixin as AsyncContextManagerMixin 

4from ._core._contextmanagers import ContextManagerMixin as ContextManagerMixin 

5from ._core._eventloop import current_time as current_time 

6from ._core._eventloop import get_all_backends as get_all_backends 

7from ._core._eventloop import get_available_backends as get_available_backends 

8from ._core._eventloop import get_cancelled_exc_class as get_cancelled_exc_class 

9from ._core._eventloop import run as run 

10from ._core._eventloop import sleep as sleep 

11from ._core._eventloop import sleep_forever as sleep_forever 

12from ._core._eventloop import sleep_until as sleep_until 

13from ._core._exceptions import BrokenResourceError as BrokenResourceError 

14from ._core._exceptions import BrokenWorkerInterpreter as BrokenWorkerInterpreter 

15from ._core._exceptions import BrokenWorkerProcess as BrokenWorkerProcess 

16from ._core._exceptions import BusyResourceError as BusyResourceError 

17from ._core._exceptions import ClosedResourceError as ClosedResourceError 

18from ._core._exceptions import ConnectionFailed as ConnectionFailed 

19from ._core._exceptions import DelimiterNotFound as DelimiterNotFound 

20from ._core._exceptions import EndOfStream as EndOfStream 

21from ._core._exceptions import IncompleteRead as IncompleteRead 

22from ._core._exceptions import NoEventLoopError as NoEventLoopError 

23from ._core._exceptions import RunFinishedError as RunFinishedError 

24from ._core._exceptions import TaskCancelled as TaskCancelled 

25from ._core._exceptions import TaskFailed as TaskFailed 

26from ._core._exceptions import TaskNotFinished as TaskNotFinished 

27from ._core._exceptions import TypedAttributeLookupError as TypedAttributeLookupError 

28from ._core._exceptions import WouldBlock as WouldBlock 

29from ._core._fileio import AsyncFile as AsyncFile 

30from ._core._fileio import Path as Path 

31from ._core._fileio import open_file as open_file 

32from ._core._fileio import wrap_file as wrap_file 

33from ._core._resources import aclose_forcefully as aclose_forcefully 

34from ._core._signals import open_signal_receiver as open_signal_receiver 

35from ._core._sockets import TCPConnectable as TCPConnectable 

36from ._core._sockets import UNIXConnectable as UNIXConnectable 

37from ._core._sockets import as_connectable as as_connectable 

38from ._core._sockets import connect_tcp as connect_tcp 

39from ._core._sockets import connect_unix as connect_unix 

40from ._core._sockets import create_connected_udp_socket as create_connected_udp_socket 

41from ._core._sockets import ( 

42 create_connected_unix_datagram_socket as create_connected_unix_datagram_socket, 

43) 

44from ._core._sockets import create_tcp_listener as create_tcp_listener 

45from ._core._sockets import create_udp_socket as create_udp_socket 

46from ._core._sockets import create_unix_datagram_socket as create_unix_datagram_socket 

47from ._core._sockets import create_unix_listener as create_unix_listener 

48from ._core._sockets import getaddrinfo as getaddrinfo 

49from ._core._sockets import getnameinfo as getnameinfo 

50from ._core._sockets import notify_closing as notify_closing 

51from ._core._sockets import wait_readable as wait_readable 

52from ._core._sockets import wait_socket_readable as wait_socket_readable 

53from ._core._sockets import wait_socket_writable as wait_socket_writable 

54from ._core._sockets import wait_writable as wait_writable 

55from ._core._streams import create_memory_object_stream as create_memory_object_stream 

56from ._core._subprocesses import open_process as open_process 

57from ._core._subprocesses import run_process as run_process 

58from ._core._synchronization import CapacityLimiter as CapacityLimiter 

59from ._core._synchronization import ( 

60 CapacityLimiterStatistics as CapacityLimiterStatistics, 

61) 

62from ._core._synchronization import Condition as Condition 

63from ._core._synchronization import ConditionStatistics as ConditionStatistics 

64from ._core._synchronization import Event as Event 

65from ._core._synchronization import EventStatistics as EventStatistics 

66from ._core._synchronization import Lock as Lock 

67from ._core._synchronization import LockStatistics as LockStatistics 

68from ._core._synchronization import ResourceGuard as ResourceGuard 

69from ._core._synchronization import Semaphore as Semaphore 

70from ._core._synchronization import SemaphoreStatistics as SemaphoreStatistics 

71from ._core._tasks import TASK_STATUS_IGNORED as TASK_STATUS_IGNORED 

72from ._core._tasks import CancelScope as CancelScope 

73from ._core._tasks import TaskHandle as TaskHandle 

74from ._core._tasks import create_task_group as create_task_group 

75from ._core._tasks import current_effective_deadline as current_effective_deadline 

76from ._core._tasks import fail_after as fail_after 

77from ._core._tasks import move_on_after as move_on_after 

78from ._core._tempfile import NamedTemporaryFile as NamedTemporaryFile 

79from ._core._tempfile import SpooledTemporaryFile as SpooledTemporaryFile 

80from ._core._tempfile import TemporaryDirectory as TemporaryDirectory 

81from ._core._tempfile import TemporaryFile as TemporaryFile 

82from ._core._tempfile import gettempdir as gettempdir 

83from ._core._tempfile import gettempdirb as gettempdirb 

84from ._core._tempfile import mkdtemp as mkdtemp 

85from ._core._tempfile import mkstemp as mkstemp 

86from ._core._testing import TaskInfo as TaskInfo 

87from ._core._testing import get_current_task as get_current_task 

88from ._core._testing import get_running_tasks as get_running_tasks 

89from ._core._testing import wait_all_tasks_blocked as wait_all_tasks_blocked 

90from ._core._typedattr import TypedAttributeProvider as TypedAttributeProvider 

91from ._core._typedattr import TypedAttributeSet as TypedAttributeSet 

92from ._core._typedattr import typed_attribute as typed_attribute 

93 

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

95for __value in list(locals().values()): 

96 if getattr(__value, "__module__", "").startswith("anyio."): 

97 __value.__module__ = __name__ 

98 

99 

100del __value 

101 

102 

103def __getattr__(attr: str) -> type[BrokenWorkerInterpreter]: 

104 """Support deprecated aliases.""" 

105 if attr == "BrokenWorkerIntepreter": 

106 import warnings 

107 

108 warnings.warn( 

109 "The 'BrokenWorkerIntepreter' alias is deprecated, use 'BrokenWorkerInterpreter' instead.", 

110 DeprecationWarning, 

111 stacklevel=2, 

112 ) 

113 return BrokenWorkerInterpreter 

114 

115 raise AttributeError(f"module {__name__!r} has no attribute {attr!r}")