Index

_

__aiter__() (machinery.helpers.protocols.Queue method) (machinery.helpers.protocols.Streamer method) (machinery.helpers.protocols.Ticker method) __await__() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) __call__() (machinery.helpers.protocols.FutureCallback method) (machinery.helpers.protocols.FutureCTXCallback method) __contains__() (machinery.helpers.protocols.TaskHolder method) __enter__() (machinery.helpers.protocols.CTX method) __exit__() (machinery.helpers.protocols.CTX method) __getitem__() (machinery._test_helpers._future_dominos.FutureDominos method) __hash__() (machinery.helpers.protocols.FutureCallback method) (machinery.helpers.protocols.FutureCTXCallback method)

__iter__() (machinery.helpers.protocols.SyncQueue method) (machinery.helpers.protocols.TaskHolder method) __len__() (machinery.helpers.protocols.Queue method) (machinery.helpers.protocols.SyncQueue method) __repr__() (machinery.helpers.protocols.WithRepr method) __type_params__ (machinery.helpers.protocols.FutureCallback attribute) (machinery.helpers.protocols.FutureCTXCallback attribute) (machinery.helpers.protocols.FutureStatus attribute) (machinery.helpers.protocols.Queue attribute) (machinery.helpers.protocols.QueueFeeder attribute) (machinery.helpers.protocols.Streamer attribute) (machinery.helpers.protocols.SyncQueue attribute) (machinery.helpers.protocols.WaitByCallback attribute)

A

add() (machinery._test_helpers._mocked_call_later.MockedCallLater method) add_async_generator() (machinery.helpers.protocols.QueueFeeder method) add_coroutine() (machinery.helpers.protocols.QueueFeeder method) (machinery.helpers.protocols.TaskHolder method) add_done_callback() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.WaitByCallback method) add_on_done() (machinery.helpers.protocols.CTX method) add_sync_function() (machinery.helpers.protocols.QueueFeeder method)

add_sync_iterator() (machinery.helpers.protocols.QueueFeeder method) add_task() (machinery.helpers.protocols.QueueFeeder method) (machinery.helpers.protocols.TaskHolder method) add_value() (machinery.helpers.protocols.QueueFeeder method) append() (machinery.helpers.protocols.Queue method) (machinery.helpers.protocols.SyncQueue method) append_instruction() (machinery.helpers.protocols.Queue method) async_as_background() (machinery.helpers.protocols.CTX method) ASYNC_GENERATOR (machinery.helpers.QueueInput attribute) async_with_timeout() (machinery.helpers.protocols.CTX method)

B

begin() (machinery._test_helpers._future_dominos.FutureDominos method)

breaker (machinery.helpers.protocols.Queue property) (machinery.helpers.protocols.Streamer property)

C

called_times (machinery._test_helpers._mocked_call_later.MockedCallLater property) cancel() (machinery._test_helpers._future_dominos.Domino method) (machinery._test_helpers._mocked_call_later.Cancellable method) (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.WaitByCallback method) Cancellable (protocol in machinery._test_helpers._mocked_call_later)

cancelled() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.FutureStatus method) change_after() (machinery.helpers.protocols.Ticker method) child() (machinery.helpers.protocols.CTX method) COROUTINE (machinery.helpers.QueueInput attribute) CTX (protocol in machinery.helpers.protocols)

D

Domino (protocol in machinery._test_helpers._future_dominos) done() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.FutureStatus method) (machinery.helpers.protocols.WaitByCallback method)

E

ensure_aexit() (in module machinery.helpers) EnsureItemGetter (class in machinery.helpers)

exception() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.FutureStatus method)

F

find_and_apply_result() (in module machinery.helpers) finished (machinery._test_helpers._future_dominos.FutureDominos property) fut_to_string() (machinery.helpers.protocols.CTX method) future_dominos() (in module machinery.test_helpers)

FutureCallback (protocol in machinery.helpers.protocols) FutureCTXCallback (protocol in machinery.helpers.protocols) FutureDominos (protocol in machinery._test_helpers._future_dominos) FutureStatus (protocol in machinery.helpers.protocols)

G

get_all (machinery.helpers.protocols.Queue property)

get_all() (machinery.helpers.protocols.SyncQueue method) get_future_name() (machinery.helpers.protocols.CTX method)

H

has_direct_done_callback() (machinery.helpers.protocols.CTX method)

I

is_empty() (machinery.helpers.protocols.Queue method) (machinery.helpers.protocols.SyncQueue method)

L

log_exception() (machinery.helpers.protocols.CTX method)

log_info() (machinery.helpers.protocols.CTX method) loop (machinery.helpers.protocols.CTX property)

M

mocked_call_later() (in module machinery.test_helpers)

MockedCallLater (protocol in machinery._test_helpers._mocked_call_later)

N

name (machinery.helpers.protocols.CTX property)

noncancelled_results_from_futs() (in module machinery.helpers)

P

pauser (machinery.helpers.protocols.Ticker property)

pending (machinery.helpers.protocols.TaskHolder property) process_after_yielded() (machinery.helpers.protocols.Queue method)

Q

Queue (protocol in machinery.helpers.protocols) queue() (in module machinery.helpers) queue_manager() (in module machinery.helpers) QueueFeeder (protocol in machinery.helpers.protocols)

QueueManagerFailure (class in machinery.helpers) QueueManagerIterationStop (class in machinery.helpers) QueueManagerStopped (class in machinery.helpers) QueueManagerSuccess (class in machinery.helpers)

R

remaining() (machinery.helpers.protocols.Queue method) (machinery.helpers.protocols.Streamer method) (machinery.helpers.protocols.SyncQueue method) remove_done_callback() (machinery.helpers.protocols.CTX method) (machinery.helpers.protocols.WaitByCallback method)

reporter (machinery.helpers.protocols.CTX property) result() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.FutureStatus method)

S

set_as_finished_if_out_of_sources() (machinery.helpers.protocols.QueueFeeder method) set_exception() (machinery._test_helpers._future_dominos.Domino method) (machinery.helpers.protocols.CTX method) set_future_name() (machinery.helpers.protocols.CTX method) set_result() (machinery._test_helpers._future_dominos.Domino method) silent_reporter (machinery.helpers.protocols.CTX property) started (machinery._test_helpers._future_dominos.FutureDominos property)

stop_async_generator() (in module machinery.helpers) Streamer (protocol in machinery.helpers.protocols) SYNC_FUNCTION (machinery.helpers.QueueInput attribute) SYNC_GENERATOR (machinery.helpers.QueueInput attribute) SYNC_ITERATOR (machinery.helpers.QueueInput attribute) sync_queue() (in module machinery.helpers) SyncQueue (protocol in machinery.helpers.protocols)

T

TASK (machinery.helpers.QueueInput attribute) task_holder() (in module machinery.helpers)

TaskHolder (protocol in machinery.helpers.protocols) tick() (in module machinery.helpers) Ticker (protocol in machinery.helpers.protocols)

V

VALUE (machinery.helpers.QueueInput attribute)

W

wait_for_all() (machinery.helpers.protocols.CTX method) wait_for_first() (machinery.helpers.protocols.CTX method)

WaitByCallback (protocol in machinery.helpers.protocols) WithRepr (protocol in machinery.helpers.protocols)