RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
rxcpp::observable< T, SourceOperator > Member List

This is the complete list of members for rxcpp::observable< T, SourceOperator >, including all inherited members.

accumulate(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
all(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
amb(AN...an) const rxcpp::observable< T, SourceOperator >inline
any(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
as_blocking(AN **...) const rxcpp::observable< T, SourceOperator >inline
as_dynamic(AN **...) const rxcpp::observable< T, SourceOperator >inline
average(AN **...) const rxcpp::observable< T, SourceOperator >inline
buffer(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
buffer_with_time(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
buffer_with_time_or_count(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
combine_latest(AN...an) const rxcpp::observable< T, SourceOperator >inline
concat(AN...an) const rxcpp::observable< T, SourceOperator >inline
concat_map(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
concat_transform(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
contains(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
count(AN **...) const rxcpp::observable< T, SourceOperator >inline
debounce(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
default_if_empty(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
delay(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
distinct(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
distinct_until_changed(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
element_at(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
exists(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
filter(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
finally(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
first(AN **...) const rxcpp::observable< T, SourceOperator >inline
flat_map(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
group_by(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
ignore_elements(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
is_empty(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
last(AN **...) const rxcpp::observable< T, SourceOperator >inline
map(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
max(AN **...) const rxcpp::observable< T, SourceOperator >inline
merge(AN...an) const rxcpp::observable< T, SourceOperator >inline
merge_transform(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
min(AN **...) const rxcpp::observable< T, SourceOperator >inline
multicast(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
observable classrxcpp::observable< T, SourceOperator >friend
observable()rxcpp::observable< T, SourceOperator >inline
observable(const source_operator_type &o)rxcpp::observable< T, SourceOperator >inlineexplicit
observable(source_operator_type &&o)rxcpp::observable< T, SourceOperator >inlineexplicit
observable(const observable< T, SO > &o)rxcpp::observable< T, SourceOperator >inline
observable(observable< T, SO > &&o)rxcpp::observable< T, SourceOperator >inline
observable_tag typedefrxcpp::observable_base< T >
observe_on(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
on_error_resume_next(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
operator==(const observable< U, SO > &, const observable< U, SO > &)rxcpp::observable< T, SourceOperator >friend
pairwise(AN...an) const rxcpp::observable< T, SourceOperator >inline
publish(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
publish_synchronized(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
reduce(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
repeat(AN...an) const rxcpp::observable< T, SourceOperator >inline
replay(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
retry(AN...an) const rxcpp::observable< T, SourceOperator >inline
sample_with_time(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
scan(AN...an) const rxcpp::observable< T, SourceOperator >inline
sequence_equal(AN...an) const rxcpp::observable< T, SourceOperator >inline
skip(AN...an) const rxcpp::observable< T, SourceOperator >inline
skip_last(AN...an) const rxcpp::observable< T, SourceOperator >inline
skip_until(AN...an) const rxcpp::observable< T, SourceOperator >inline
source_operatorrxcpp::observable< T, SourceOperator >mutable
source_operator_type typedefrxcpp::observable< T, SourceOperator >
start_with(AN...an) const rxcpp::observable< T, SourceOperator >inline
subscribe(ArgN &&...an) const -> composite_subscriptionrxcpp::observable< T, SourceOperator >inline
subscribe_on(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
sum(AN **...) const rxcpp::observable< T, SourceOperator >inline
switch_if_empty(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
switch_on_error(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
switch_on_next(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
take(AN...an) const rxcpp::observable< T, SourceOperator >inline
take_last(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
take_until(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
take_while(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
tap(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
time_interval(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
timeout(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
timestamp(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
transform(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
value_type typedefrxcpp::observable< T, SourceOperator >
window(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
window_toggle(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
window_with_time(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
window_with_time_or_count(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
with_latest_from(AN...an) const rxcpp::observable< T, SourceOperator >inline
zip(AN &&...an) const rxcpp::observable< T, SourceOperator >inline
~observable()rxcpp::observable< T, SourceOperator >inline