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::test::testable_observable< T > Member List

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

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