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
|
Z
_
__asynccontextmanager__() (anyio.AsyncContextManagerMixin method)
__contextmanager__() (anyio.ContextManagerMixin method)
A
accept() (anyio.abc.SocketListener method)
accumulate() (in module anyio.itertools)
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
batched() (in module anyio.itertools)
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.abc.TaskGroup method)
(anyio.CancelScope method)
(anyio.TaskHandle method)
cancel_called (anyio.CancelScope property)
cancel_shielded_checkpoint() (in module anyio.lowlevel)
CANCELLED (anyio.TaskHandle.Status attribute)
cancelled_caught (anyio.CancelScope property)
CANCELLING (anyio.TaskHandle.Status attribute)
CancelScope (class in anyio)
CapacityLimiter (class in anyio)
CapacityLimiterStatistics (class in anyio)
Chain (class in anyio.itertools)
chain (in module anyio.itertools)
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
combinations() (in module anyio.itertools)
combinations_with_replacement() (in module anyio.itertools)
compress() (in module anyio.itertools)
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)
coro (anyio.TaskHandle property)
count() (in module anyio.itertools)
create_connected_udp_socket() (in module anyio)
create_memory_object_stream() (in module anyio)
create_task() (anyio.abc.TaskGroup method)
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)
cycle() (in module anyio.itertools)
D
deadline (anyio.CancelScope property)
DelimiterNotFound
dropwhile() (in module anyio.itertools)
E
EndOfStream
Event (class in anyio)
EventLoopToken (class in anyio.lowlevel)
EventStatistics (class in anyio)
exception (anyio.TaskHandle property)
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)
FAILED (anyio.TaskHandle.Status attribute)
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)
filterfalse() (in module anyio.itertools)
FINISHED (anyio.TaskHandle.Status attribute)
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() (anyio.lowlevel.RunVar method)
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)
groupby() (in module anyio.itertools)
H
handle_handshake_error() (anyio.streams.tls.TLSListener static method)
has_pending_cancellation() (anyio.TaskInfo method)
I
IncompleteRead
is_set() (anyio.Event method)
islice() (in module anyio.itertools)
K
kill() (anyio.abc.Process method)
kind (anyio.pytest_plugin.FreePortFactory property)
L
limiter (anyio.AsyncFile property)
(anyio.Path property)
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
name (anyio.TaskHandle property)
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
pairwise() (in module anyio.itertools)
path (anyio.streams.file.FileStreamAttribute attribute)
Path (class in anyio)
peer_certificate_binary (anyio.streams.tls.TLSAttribute attribute)
PENDING (anyio.TaskHandle.Status attribute)
permutations() (in module anyio.itertools)
pid (anyio.abc.Process property)
Process (class in anyio.abc)
product() (in module anyio.itertools)
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)
repeat() (in module anyio.itertools)
reset() (anyio.lowlevel.RunVar method)
ResourceGuard (class in anyio)
return_value (anyio.TaskHandle property)
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)
(anyio.lowlevel.RunVar 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)
starmap() (in module anyio.itertools)
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)
start_value (anyio.TaskHandle property)
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)
status (anyio.TaskHandle property)
stderr (anyio.abc.Process property)
stdin (anyio.abc.Process property)
stdout (anyio.abc.Process property)
stop() (anyio.from_thread.BlockingPortal method)
T
takewhile() (in module anyio.itertools)
TaskCancelled
TaskFailed
TaskGroup (class in anyio.abc)
TaskHandle (class in anyio)
TaskHandle.Status (class in anyio)
TaskInfo (class in anyio)
TaskNotFinished
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)
tee() (in module anyio.itertools)
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)
(anyio.TaskHandle 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)
Z
zip_longest() (in module anyio.itertools)