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_delay_error(AN... an) constrxcpp::observable< T, detail::test_source< T > >inline
merge_transform(AN &&... an) constrxcpp::observable< T, detail::test_source< T > >inline
messages() constrxcpp::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
skip_while(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() constrxcpp::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