Index

_ | A | C | D | E | F | G | I | K | L | M | N | O | P | R | S | T | U | V | W

_

__init__() (streams.poolofpools.ExecutorPool method)
(streams.Stream method)
__iter__() (streams.Stream method)
__len__() (streams.Stream method)
__reversed__() (streams.Stream method)
__weakref__ (streams.poolofpools.ExecutorPool attribute)
(streams.poolofpools.PoolOfPools attribute)

A

accumulate() (in module streams.iterators)
all() (streams.Stream method)
any() (streams.Stream method)
apply_to_tuple() (in module streams.utils)
average() (streams.Stream method)

C

cache() (streams.Stream method)
chain() (streams.Stream method)
concat() (streams.Stream class method)
count() (streams.Stream method)

D

decimal_or_none() (in module streams.utils)
decimals() (streams.Stream method)
distinct() (in module streams.iterators)
(streams.Stream method)
divisible_by() (streams.Stream method)
dummy_callback() (streams.executors.mixins.PoolOfPoolsMixin static method)

E

evens() (streams.Stream method)
exclude() (streams.Stream method)
exclude_nones() (streams.Stream method)
ExecutorPool (class in streams.poolofpools)
expand() (streams.executors.mixins.PoolOfPoolsMixin method)

F

filter() (streams.Stream method)
filter_false() (in module streams.utils)
filter_keys() (in module streams.utils)
filter_true() (in module streams.utils)
filter_values() (in module streams.utils)
first (streams.Stream attribute)
float_or_none() (in module streams.utils)
floats() (streams.Stream method)

G

get() (streams.poolofpools.ExecutorPool method)
(streams.poolofpools.PoolOfPools method)
get_any() (streams.poolofpools.ExecutorPool method)
get_first() (streams.executors.mixins.PoolOfPoolsMixin static method)
get_from_pool() (streams.poolofpools.PoolOfPools static method)
get_suitable_worker() (streams.poolofpools.ExecutorPool method)
GeventExecutor (class in streams.executors._gevent)
GreenletFuture (class in streams.executors._gevent)

I

instances_of() (streams.Stream method)
int_or_none() (in module streams.utils)
ints() (streams.Stream method)
iterate() (streams.Stream class method)

K

key_map() (streams.Stream method)
key_mapper() (in module streams.utils)
keys() (streams.Stream method)

L

largest() (streams.Stream method)
limit() (streams.Stream method)
long_or_none() (in module streams.utils)
longs() (streams.Stream method)

M

make_list() (in module streams.utils)
map() (streams.executors.mixins.PoolOfPoolsMixin method)
(streams.Stream method)
MaxHeapItem (class in streams.utils)
median() (streams.Stream method)

N

name_to_worker_mapping() (streams.poolofpools.ExecutorPool method)
nth() (streams.Stream method)

O

odds() (streams.Stream method)
only_falses() (streams.Stream method)
only_nones() (streams.Stream method)
only_trues() (streams.Stream method)

P

parallel() (streams.poolofpools.PoolOfPools method)
partly_distinct() (in module streams.iterators)
(streams.Stream method)
peek() (in module streams.iterators)
(streams.Stream method)
PoolOfPools (class in streams.poolofpools)
PoolOfPoolsMixin (class in streams.executors.mixins)
process() (streams.poolofpools.PoolOfPools method)
ProcessPoolExecutor (class in streams.executors.executors)

R

range() (streams.Stream class method)
real_worker_availability() (streams.poolofpools.ExecutorPool method)
reduce() (streams.Stream method)
regexp() (streams.Stream method)
reversed() (streams.Stream method)

S

seed() (in module streams.iterators)
SequentalExecutor (class in streams.executors.executors)
skip() (streams.Stream method)
smallest() (streams.Stream method)
sorted() (streams.Stream method)
squash() (streams.poolofpools.ExecutorPool method)
squash_workers() (streams.poolofpools.ExecutorPool method)
Stream (class in streams)
streams (module)
streams.executors (module)
streams.executors._gevent (module)
streams.executors.executors (module)
streams.executors.mixins (module)
streams.iterators (module)
streams.poolofpools (module)
streams.utils (module)
strings() (streams.Stream method)
sum() (streams.Stream method)

T

ThreadPoolExecutor (class in streams.executors.executors)
tuplify() (streams.Stream method)

U

unicode_or_none() (in module streams.utils)

V

value_map() (streams.Stream method)
value_mapper() (in module streams.utils)
values() (streams.Stream method)

W

worker_finished() (streams.poolofpools.ExecutorPool method)