AnyIO
The basics
Creating and managing tasks
Cancellation and timeouts
Using synchronization primitives
Streams
Using typed attributes
Using sockets and streams
Working with threads
Using subprocesses
Working with subinterpreters
Asynchronous file I/O support
Asynchronous Temporary File and Directory
Receiving operating system signals
Context manager mix-in classes
Testing with AnyIO
API reference
Migrating from AnyIO 3 to AnyIO 4
Migrating from AnyIO 2 to AnyIO 3
Why you should be using AnyIO APIs instead of asyncio APIs
Frequently Asked Questions
Getting help
Reporting bugs
Contributing to AnyIO
Version history
AnyIO
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__asynccontextmanager__() (anyio.AsyncContextManagerMixin method)
__contextmanager__() (anyio.ContextManagerMixin method)
A
accept() (anyio.abc.SocketListener method)
aclose() (anyio.abc.AsyncResource method)
(anyio.AsyncFile method)
(anyio.SpooledTemporaryFile method)
(anyio.streams.buffered.BufferedByteReceiveStream method)
(anyio.streams.memory.MemoryObjectReceiveStream method)
(anyio.streams.memory.MemoryObjectSendStream method)
(anyio.streams.stapled.MultiListener method)
(anyio.streams.stapled.StapledByteStream method)
(anyio.streams.stapled.StapledObjectStream method)
(anyio.streams.text.TextReceiveStream method)
(anyio.streams.text.TextSendStream method)
(anyio.streams.text.TextStream method)
(anyio.streams.tls.TLSListener method)
(anyio.streams.tls.TLSStream method)
aclose_forcefully() (in module anyio)
acquire() (anyio.CapacityLimiter method)
(anyio.Condition method)
(anyio.Lock method)
(anyio.Semaphore method)
acquire_nowait() (anyio.CapacityLimiter method)
(anyio.Condition method)
(anyio.Lock method)
(anyio.Semaphore method)
acquire_on_behalf_of() (anyio.CapacityLimiter method)
acquire_on_behalf_of_nowait() (anyio.CapacityLimiter method)
alpn_protocol (anyio.streams.tls.TLSAttribute attribute)
AnyByteReceiveStream (in module anyio.abc)
AnyByteSendStream (in module anyio.abc)
AnyByteStream (in module anyio.abc)
AnyByteStreamConnectable (in module anyio.abc)
AnyUnreliableByteReceiveStream (in module anyio.abc)
AnyUnreliableByteSendStream (in module anyio.abc)
AnyUnreliableByteStream (in module anyio.abc)
as_connectable() (in module anyio)
AsyncContextManagerMixin (class in anyio)
AsyncFile (class in anyio)
AsyncResource (class in anyio.abc)
available_tokens (anyio.CapacityLimiter property)
B
BlockingPortal (class in anyio.from_thread)
BlockingPortalProvider (class in anyio.from_thread)
borrowed_tokens (anyio.CapacityLimiter property)
BrokenResourceError
BrokenWorkerInterpreter
BrokenWorkerProcess
buffer (anyio.streams.buffered.BufferedByteReceiveStream property)
BufferedByteReceiveStream (class in anyio.streams.buffered)
BufferedByteStream (class in anyio.streams.buffered)
BusyResourceError
ByteReceiveStream (class in anyio.abc)
ByteSendStream (class in anyio.abc)
ByteStream (class in anyio.abc)
ByteStreamConnectable (class in anyio.abc)
C
cache() (in module anyio.functools)
call() (anyio.from_thread.BlockingPortal method)
cancel() (anyio.CancelScope method)
cancel_called (anyio.CancelScope property)
cancel_shielded_checkpoint() (in module anyio.lowlevel)
cancelled_caught (anyio.CancelScope property)
CancelScope (class in anyio)
CapacityLimiter (class in anyio)
CapacityLimiterStatistics (class in anyio)
channel_binding_tls_unique (anyio.streams.tls.TLSAttribute attribute)
check_cancelled() (in module anyio.from_thread)
checkpoint() (in module anyio.lowlevel)
checkpoint_if_cancelled() (in module anyio.lowlevel)
cipher (anyio.streams.tls.TLSAttribute attribute)
clone() (anyio.streams.memory.MemoryObjectReceiveStream method)
(anyio.streams.memory.MemoryObjectSendStream method)
close() (anyio.streams.memory.MemoryObjectReceiveStream method)
(anyio.streams.memory.MemoryObjectSendStream method)
ClosedResourceError
Condition (class in anyio)
ConditionStatistics (class in anyio)
connect() (anyio.abc.ByteStreamConnectable method)
(anyio.abc.ObjectStreamConnectable method)
(anyio.streams.text.TextConnectable method)
(anyio.streams.tls.TLSConnectable method)
(anyio.TCPConnectable method)
(anyio.UNIXConnectable method)
connect_tcp() (in module anyio)
connect_unix() (in module anyio)
ConnectedUDPSocket (class in anyio.abc)
ConnectedUNIXDatagramSocket (class in anyio.abc)
ConnectionFailed
ContextManagerMixin (class in anyio)
create_connected_udp_socket() (in module anyio)
create_memory_object_stream() (in module anyio)
create_task_group() (in module anyio)
create_tcp_listener() (in module anyio)
create_udp_socket() (in module anyio)
create_unix_listener() (in module anyio)
current_buffer_used (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
current_default_interpreter_limiter() (in module anyio.to_interpreter)
current_default_process_limiter() (in module anyio.to_process)
current_default_thread_limiter() (in module anyio.to_thread)
current_effective_deadline() (in module anyio)
current_time() (in module anyio)
current_token() (in module anyio.lowlevel)
D
deadline (anyio.CancelScope property)
DelimiterNotFound
E
EndOfStream
Event (class in anyio)
EventLoopToken (class in anyio.lowlevel)
EventStatistics (class in anyio)
extra() (anyio.TypedAttributeProvider method)
extra_attributes (anyio.streams.buffered.BufferedByteReceiveStream property)
(anyio.streams.stapled.MultiListener property)
(anyio.streams.stapled.StapledByteStream property)
(anyio.streams.stapled.StapledObjectStream property)
(anyio.streams.text.TextReceiveStream property)
(anyio.streams.text.TextSendStream property)
(anyio.streams.text.TextStream property)
(anyio.streams.tls.TLSListener property)
(anyio.streams.tls.TLSStream property)
(anyio.TypedAttributeProvider property)
F
fail_after() (in module anyio)
family (anyio.abc.SocketAttribute attribute)
feed_data() (anyio.streams.buffered.BufferedByteReceiveStream method)
file (anyio.streams.file.FileStreamAttribute attribute)
fileno (anyio.streams.file.FileStreamAttribute attribute)
FileReadStream (class in anyio.streams.file)
FileStreamAttribute (class in anyio.streams.file)
FileWriteStream (class in anyio.streams.file)
FreePortFactory (class in anyio.pytest_plugin)
from_path() (anyio.streams.file.FileReadStream class method)
(anyio.streams.file.FileWriteStream class method)
from_socket() (anyio.abc.ConnectedUDPSocket class method)
(anyio.abc.ConnectedUNIXDatagramSocket class method)
(anyio.abc.SocketListener class method)
(anyio.abc.SocketStream class method)
(anyio.abc.UDPSocket class method)
(anyio.abc.UNIXDatagramSocket class method)
(anyio.abc.UNIXSocketStream class method)
G
get_all_backends() (in module anyio)
get_available_backends() (in module anyio)
get_cancelled_exc_class() (in module anyio)
get_current_task() (in module anyio)
get_running_tasks() (in module anyio)
getaddrinfo() (in module anyio)
getnameinfo() (in module anyio)
gettempdir() (in module anyio)
gettempdirb() (in module anyio)
H
handle_handshake_error() (anyio.streams.tls.TLSListener static method)
has_pending_cancellation() (anyio.TaskInfo method)
I
IncompleteRead
is_set() (anyio.Event method)
K
kill() (anyio.abc.Process method)
kind (anyio.pytest_plugin.FreePortFactory property)
L
Listener (class in anyio.abc)
local_address (anyio.abc.SocketAttribute attribute)
local_port (anyio.abc.SocketAttribute attribute)
Lock (class in anyio)
locked() (anyio.Condition method)
(anyio.Lock method)
LockStatistics (class in anyio)
lru_cache() (in module anyio.functools)
M
max_buffer_size (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
max_value (anyio.Semaphore property)
MemoryObjectReceiveStream (class in anyio.streams.memory)
MemoryObjectSendStream (class in anyio.streams.memory)
MemoryObjectStreamStatistics (class in anyio.streams.memory)
mkdtemp() (in module anyio)
mkstemp() (in module anyio)
move_on_after() (in module anyio)
MultiListener (class in anyio.streams.stapled)
N
NamedTemporaryFile (class in anyio)
NoEventLoopError
notify() (anyio.Condition method)
notify_all() (anyio.Condition method)
O
ObjectReceiveStream (class in anyio.abc)
ObjectSendStream (class in anyio.abc)
ObjectStream (class in anyio.abc)
ObjectStreamConnectable (class in anyio.abc)
open_file() (in module anyio)
open_process() (in module anyio)
open_receive_streams (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
open_send_streams (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
open_signal_receiver() (in module anyio)
P
path (anyio.streams.file.FileStreamAttribute attribute)
Path (class in anyio)
peer_certificate_binary (anyio.streams.tls.TLSAttribute attribute)
pid (anyio.abc.Process property)
Process (class in anyio.abc)
Python Enhancement Proposals
PEP 561
PEP 654
R
raw_socket (anyio.abc.SocketAttribute attribute)
receive() (anyio.abc.ByteReceiveStream method)
(anyio.abc.UnreliableObjectReceiveStream method)
(anyio.streams.buffered.BufferedByteReceiveStream method)
(anyio.streams.file.FileReadStream method)
(anyio.streams.memory.MemoryObjectReceiveStream method)
(anyio.streams.stapled.StapledByteStream method)
(anyio.streams.stapled.StapledObjectStream method)
(anyio.streams.text.TextReceiveStream method)
(anyio.streams.text.TextStream method)
(anyio.streams.tls.TLSStream method)
receive_exactly() (anyio.streams.buffered.BufferedByteReceiveStream method)
receive_fds() (anyio.abc.UNIXSocketStream method)
receive_nowait() (anyio.streams.memory.MemoryObjectReceiveStream method)
receive_until() (anyio.streams.buffered.BufferedByteReceiveStream method)
reduce() (in module anyio.functools)
release() (anyio.CapacityLimiter method)
(anyio.Condition method)
(anyio.Lock method)
(anyio.Semaphore method)
release_on_behalf_of() (anyio.CapacityLimiter method)
remote_address (anyio.abc.SocketAttribute attribute)
remote_port (anyio.abc.SocketAttribute attribute)
ResourceGuard (class in anyio)
returncode (anyio.abc.Process property)
RFC
RFC 6555
run() (in module anyio)
(in module anyio.from_thread)
run_process() (in module anyio)
run_sync() (in module anyio.from_thread)
(in module anyio.to_interpreter)
(in module anyio.to_process)
(in module anyio.to_thread)
RunFinishedError
RunVar (class in anyio.lowlevel)
S
seek() (anyio.streams.file.FileReadStream method)
Semaphore (class in anyio)
SemaphoreStatistics (class in anyio)
send() (anyio.abc.ByteSendStream method)
(anyio.abc.UnreliableObjectSendStream method)
(anyio.streams.buffered.BufferedByteStream method)
(anyio.streams.file.FileWriteStream method)
(anyio.streams.memory.MemoryObjectSendStream method)
(anyio.streams.stapled.StapledByteStream method)
(anyio.streams.stapled.StapledObjectStream method)
(anyio.streams.text.TextSendStream method)
(anyio.streams.text.TextStream method)
(anyio.streams.tls.TLSStream method)
send_eof() (anyio.abc.ByteStream method)
(anyio.abc.ObjectStream method)
(anyio.streams.buffered.BufferedByteStream method)
(anyio.streams.stapled.StapledByteStream method)
(anyio.streams.stapled.StapledObjectStream method)
(anyio.streams.text.TextStream method)
(anyio.streams.tls.TLSStream method)
send_fds() (anyio.abc.UNIXSocketStream method)
send_nowait() (anyio.streams.memory.MemoryObjectSendStream method)
send_signal() (anyio.abc.Process method)
sendto() (anyio.abc.UDPSocket method)
(anyio.abc.UNIXDatagramSocket method)
serve() (anyio.abc.Listener method)
(anyio.abc.SocketListener method)
(anyio.streams.stapled.MultiListener method)
(anyio.streams.tls.TLSListener method)
server_side (anyio.streams.tls.TLSAttribute attribute)
set() (anyio.Event method)
shared_ciphers (anyio.streams.tls.TLSAttribute attribute)
shield (anyio.CancelScope property)
sleep() (in module anyio)
sleep_forever() (in module anyio)
sleep_until() (in module anyio)
sleep_until_stopped() (anyio.from_thread.BlockingPortal method)
SocketAttribute (class in anyio.abc)
SocketListener (class in anyio.abc)
SocketStream (class in anyio.abc)
SpooledTemporaryFile (class in anyio)
ssl_object (anyio.streams.tls.TLSAttribute attribute)
standard_compatible (anyio.streams.tls.TLSAttribute attribute)
StapledByteStream (class in anyio.streams.stapled)
StapledObjectStream (class in anyio.streams.stapled)
start() (anyio.abc.TaskGroup method)
start_blocking_portal() (in module anyio.from_thread)
start_soon() (anyio.abc.TaskGroup method)
start_task() (anyio.from_thread.BlockingPortal method)
start_task_soon() (anyio.from_thread.BlockingPortal method)
started() (anyio.abc.TaskStatus method)
statistics() (anyio.CapacityLimiter method)
(anyio.Condition method)
(anyio.Event method)
(anyio.Lock method)
(anyio.Semaphore method)
(anyio.streams.memory.MemoryObjectReceiveStream method)
(anyio.streams.memory.MemoryObjectSendStream method)
stderr (anyio.abc.Process property)
stdin (anyio.abc.Process property)
stdout (anyio.abc.Process property)
stop() (anyio.from_thread.BlockingPortal method)
T
TaskGroup (class in anyio.abc)
TaskInfo (class in anyio)
tasks_waiting_receive (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
tasks_waiting_send (anyio.streams.memory.MemoryObjectStreamStatistics attribute)
TaskStatus (class in anyio.abc)
TCPConnectable (class in anyio)
tell() (anyio.streams.file.FileReadStream method)
TemporaryDirectory (class in anyio)
TemporaryFile (class in anyio)
terminate() (anyio.abc.Process method)
TextConnectable (class in anyio.streams.text)
TextReceiveStream (class in anyio.streams.text)
TextSendStream (class in anyio.streams.text)
TextStream (class in anyio.streams.text)
tls_version (anyio.streams.tls.TLSAttribute attribute)
TLSAttribute (class in anyio.streams.tls)
TLSConnectable (class in anyio.streams.tls)
TLSListener (class in anyio.streams.tls)
TLSStream (class in anyio.streams.tls)
total_tokens (anyio.CapacityLimiter property)
typed_attribute() (in module anyio)
TypedAttributeLookupError
TypedAttributeProvider (class in anyio)
TypedAttributeSet (class in anyio)
U
UDPSocket (class in anyio.abc)
UNIXConnectable (class in anyio)
UNIXDatagramSocket (class in anyio.abc)
UNIXSocketStream (class in anyio.abc)
UnreliableObjectReceiveStream (class in anyio.abc)
UnreliableObjectSendStream (class in anyio.abc)
UnreliableObjectStream (class in anyio.abc)
unwrap() (anyio.streams.tls.TLSStream method)
V
value (anyio.Semaphore property)
W
wait() (anyio.abc.Process method)
(anyio.Condition method)
(anyio.Event method)
wait_all_tasks_blocked() (in module anyio)
wait_for() (anyio.Condition method)
wait_readable() (in module anyio)
wait_socket_readable() (in module anyio)
wait_socket_writable() (in module anyio)
wait_writable() (in module anyio)
WouldBlock
wrap() (anyio.streams.tls.TLSStream class method)
wrap_async_context_manager() (anyio.from_thread.BlockingPortal method)
wrap_file() (in module anyio)
wrapped (anyio.AsyncFile property)
write() (anyio.SpooledTemporaryFile method)
writelines() (anyio.SpooledTemporaryFile method)