Index

A

aclose() (async_wrapper.queue.Queue method) aget() (async_wrapper.queue.Queue method) agetter (async_wrapper.queue.Queue property) AlreadyDisposedError aput() (async_wrapper.queue.Queue method) aputter (async_wrapper.queue.Queue property) async_to_sync() (in module async_wrapper.convert) async_wrapper.convert module

async_wrapper.exception module async_wrapper.pipe module async_wrapper.queue module async_wrapper.task_group module async_wrapper.wait module

C

cancel_scope (async_wrapper.task_group.TaskGroupWrapper property) clone (async_wrapper.queue.Queue property) close() (async_wrapper.queue.Queue method) Completed (class in async_wrapper.wait)

copy() (async_wrapper.wait.Waiter method) create_disposable() (in module async_wrapper.pipe) create_queue() (in module async_wrapper.queue) create_task_group_wrapper() (in module async_wrapper.task_group)

D

Disposable (class in async_wrapper.pipe) DisposableError DisposableWithCallback (class in async_wrapper.pipe)

dispose() (async_wrapper.pipe.Disposable method) (async_wrapper.pipe.Pipe method) (async_wrapper.pipe.SimpleDisposable method)

E

empty() (async_wrapper.queue.Queue method)

F

full() (async_wrapper.queue.Queue method)

G

get() (async_wrapper.queue.Queue method)

getter (async_wrapper.queue.Queue property)

I

is_disposed (async_wrapper.pipe.Disposable property) (async_wrapper.pipe.Pipe property) (async_wrapper.pipe.SimpleDisposable property)

is_ready (async_wrapper.task_group.SoonValue property) is_set() (async_wrapper.wait.Waiter method)

M

maxsize (async_wrapper.queue.Queue property) module async_wrapper.convert async_wrapper.exception async_wrapper.pipe async_wrapper.queue async_wrapper.task_group async_wrapper.wait

N

next() (async_wrapper.pipe.Disposable method) (async_wrapper.pipe.Pipe method) (async_wrapper.pipe.SimpleDisposable method)

P

PendingError Pipe (class in async_wrapper.pipe) prepare_callback() (async_wrapper.pipe.DisposableWithCallback method) (async_wrapper.pipe.SimpleDisposable method)

put() (async_wrapper.queue.Queue method) putter (async_wrapper.queue.Queue property)

Q

qsize() (async_wrapper.queue.Queue method) Queue (class in async_wrapper.queue) QueueBrokenError QueueClosedError

QueueEmptyError QueueError QueueFullError QueueRestrictedError

S

set() (async_wrapper.wait.Waiter method) SimpleDisposable (class in async_wrapper.pipe) size (async_wrapper.pipe.Pipe property) (async_wrapper.pipe.Subscribable property) SoonValue (class in async_wrapper.task_group) start_soon() (async_wrapper.task_group.TaskGroupWrapper method) (async_wrapper.wait.Completed method)

statistics() (async_wrapper.queue.Queue method) (async_wrapper.wait.Waiter method) Subscribable (class in async_wrapper.pipe) subscribe() (async_wrapper.pipe.Pipe method) (async_wrapper.pipe.Subscribable method) sync_to_async() (in module async_wrapper.convert)

T

TaskGroupWrapper (class in async_wrapper.task_group)

toggle_func() (in module async_wrapper.convert)

U

unsubscribe() (async_wrapper.pipe.Pipe method) (async_wrapper.pipe.Subscribable method)

V

value (async_wrapper.task_group.SoonValue property)

W

wait() (async_wrapper.wait.Waiter method) wait_for() (in module async_wrapper.wait)

Waiter (class in async_wrapper.wait) wrap() (async_wrapper.task_group.TaskGroupWrapper method)