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