Streams
latest
Installation
User Guide
Streams API
Internal modules
Streams
Docs
»
Edit on GitHub
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)
Read the Docs
v: latest
Versions
latest
stable
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.