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

Shortcuts on this page

r m x   toggle line displays

j k   next/prev highlighted chunk

0   (zero) top of page

1   (one) first highlighted chunk

44 statements  

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__