1from __future__ import annotations
2
3from typing import Any
4
5from ._eventloop import AsyncBackend as AsyncBackend
6from ._resources import AsyncResource as AsyncResource
7from ._sockets import ConnectedUDPSocket as ConnectedUDPSocket
8from ._sockets import ConnectedUNIXDatagramSocket as ConnectedUNIXDatagramSocket
9from ._sockets import IPAddressType as IPAddressType
10from ._sockets import IPSockAddrType as IPSockAddrType
11from ._sockets import SocketAttribute as SocketAttribute
12from ._sockets import SocketListener as SocketListener
13from ._sockets import SocketStream as SocketStream
14from ._sockets import UDPPacketType as UDPPacketType
15from ._sockets import UDPSocket as UDPSocket
16from ._sockets import UNIXDatagramPacketType as UNIXDatagramPacketType
17from ._sockets import UNIXDatagramSocket as UNIXDatagramSocket
18from ._sockets import UNIXSocketStream as UNIXSocketStream
19from ._streams import AnyByteReceiveStream as AnyByteReceiveStream
20from ._streams import AnyByteSendStream as AnyByteSendStream
21from ._streams import AnyByteStream as AnyByteStream
22from ._streams import AnyUnreliableByteReceiveStream as AnyUnreliableByteReceiveStream
23from ._streams import AnyUnreliableByteSendStream as AnyUnreliableByteSendStream
24from ._streams import AnyUnreliableByteStream as AnyUnreliableByteStream
25from ._streams import ByteReceiveStream as ByteReceiveStream
26from ._streams import ByteSendStream as ByteSendStream
27from ._streams import ByteStream as ByteStream
28from ._streams import Listener as Listener
29from ._streams import ObjectReceiveStream as ObjectReceiveStream
30from ._streams import ObjectSendStream as ObjectSendStream
31from ._streams import ObjectStream as ObjectStream
32from ._streams import UnreliableObjectReceiveStream as UnreliableObjectReceiveStream
33from ._streams import UnreliableObjectSendStream as UnreliableObjectSendStream
34from ._streams import UnreliableObjectStream as UnreliableObjectStream
35from ._subprocesses import Process as Process
36from ._tasks import TaskGroup as TaskGroup
37from ._tasks import TaskStatus as TaskStatus
38from ._testing import TestRunner as TestRunner
39
40# Re-exported here, for backwards compatibility
41# isort: off
42from .._core._synchronization import (
43 CapacityLimiter as CapacityLimiter,
44 Condition as Condition,
45 Event as Event,
46 Lock as Lock,
47 Semaphore as Semaphore,
48)
49from .._core._tasks import CancelScope as CancelScope
50from ..from_thread import BlockingPortal as BlockingPortal
51
52# Re-export imports so they look like they live directly in this package
53key: str
54value: Any
55for key, value in list(locals().items()):
56 if getattr(value, "__module__", "").startswith("anyio.abc."):
57 value.__module__ = __name__