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++.
Class Hierarchy

Go to the graphical class hierarchy

This inheritance list is sorted roughly, but not completely, alphabetically:
[detail level 1234]
 Crxcpp::schedulers::action_base
 Crxcpp::all_tag
 Crxcpp::util::all_true< BN >
 Crxcpp::util::all_true< B >
 Crxcpp::util::all_true< B, BN... >
 Crxcpp::util::all_true_type< BN >
 Crxcpp::util::all_true_type< B >
 Crxcpp::util::all_true_type< B, BN... >
 Crxcpp::util::all_values_true
 Crxcpp::amb_tag
 Crxcpp::any_tag
 Crxcpp::util::any_value_true
 Crxcpp::subjects::behavior< T >
 Crxcpp::blocking_observable< T, Observable >Source of values whose methods block until all values have been emitted. subscribe or use one of the operator methods that reduce the values emitted to a single value
 Crxcpp::buffer_count_tag
 Crxcpp::buffer_with_time_or_count_tag
 Crxcpp::buffer_with_time_tag
 Ccpplinq::collection_tag
 Crxcpp::combine_latest_tag
 Crxcpp::detail::composite_subscription_inner
 Crxcpp::concat_map_tag
 Crxcpp::concat_tag
 Cconditional
 Crxcpp::connect_forever_tag
 Ccpplinq::container_interface< T >
 Ccpplinq::container_range< Container >
 Ccpplinq::util::container_traits< Container >
 Crxcpp::coordination_base
 Crxcpp::coordinator_base
 Crxcpp::util::count
 Ccpplinq::linq_groupby< Collection, KeyFn, Compare >::cursor
 Ccpplinq::linq_select< Collection, Selector >::cursor
 Ccpplinq::linq_where< Collection, Predicate >::cursor
 Ccpplinq::linq_select_many< Container1, Fn, Fn2 >::cursor
 Ccpplinq::cursor_interface< T >
 Ccpplinq::util::cursor_type< Collection >
 Crxcpp::debounce_tag
 Ccpplinq::default_equality
 Ccpplinq::default_less
 Crxcpp::util::defer_seed_type< Deferred, AN >
 Crxcpp::util::defer_trait< Deferred, AN >
 Crxcpp::util::defer_type< Deferred, AN >
 Crxcpp::util::defer_value_type< Deferred, AN >
 Crxcpp::delay_tag
 Crxcpp::delayed_type< T, AN >
 Crxcpp::distinct_tag
 Crxcpp::distinct_until_changed_tag
 Ccpplinq::dynamic_collection< T >
 Crxcpp::element_at_tag
 Cenable_shared_from_this
 Crxcpp::util::equal_to< T >
 Crxcpp::util::equal_to< void >
 Crxcpp::expand_observable_tags< Types, class >
 Crxcpp::expand_observable_tags< rxu::types< ObservableN... >, rxu::types_checked_t< typename ObservableN::observable_tag... > >
 Crxcpp::util::expand_value_types< Types, class >
 Crxcpp::util::expand_value_types< types< TN... >, types_checked_t< typename std::decay< TN >::type::value_type... > >
 Cfalse_type
 Crxcpp::filter_tag
 Crxcpp::filtered_hash< T, typename >
 Crxcpp::filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::duration< typename T::rep, typename T::period > >::value >::type >
 Crxcpp::filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::time_point< typename T::clock, typename T::duration > >::value >::type >
 Crxcpp::finally_tag
 Crxcpp::flat_map_tag
 Crxcpp::coordinator< Input >::get< T >
 Ccpplinq::group< Iter, Key >
 Crxcpp::group_by_tag
 Chash
 Ccpplinq::util::identity< Type >
 Crxcpp::identity_for< T >
 Crxcpp::identity_observable
 Crxcpp::ignore_elements_tag
 Crxcpp::amb_tag::include_header< Included >
 Crxcpp::all_tag::include_header< Included >
 Crxcpp::any_tag::include_header< Included >
 Crxcpp::buffer_count_tag::include_header< Included >
 Crxcpp::buffer_with_time_tag::include_header< Included >
 Crxcpp::buffer_with_time_or_count_tag::include_header< Included >
 Crxcpp::combine_latest_tag::include_header< Included >
 Crxcpp::concat_tag::include_header< Included >
 Crxcpp::concat_map_tag::include_header< Included >
 Crxcpp::connect_forever_tag::include_header< Included >
 Crxcpp::debounce_tag::include_header< Included >
 Crxcpp::delay_tag::include_header< Included >
 Crxcpp::distinct_tag::include_header< Included >
 Crxcpp::distinct_until_changed_tag::include_header< Included >
 Crxcpp::element_at_tag::include_header< Included >
 Crxcpp::filter_tag::include_header< Included >
 Crxcpp::finally_tag::include_header< Included >
 Crxcpp::flat_map_tag::include_header< Included >
 Crxcpp::group_by_tag::include_header< Included >
 Crxcpp::ignore_elements_tag::include_header< Included >
 Crxcpp::map_tag::include_header< Included >
 Crxcpp::merge_tag::include_header< Included >
 Crxcpp::multicast_tag::include_header< Included >
 Crxcpp::observe_on_tag::include_header< Included >
 Crxcpp::on_error_resume_next_tag::include_header< Included >
 Crxcpp::reduce_tag::include_header< Included >
 Crxcpp::ref_count_tag::include_header< Included >
 Crxcpp::pairwise_tag::include_header< Included >
 Crxcpp::publish_tag::include_header< Included >
 Crxcpp::repeat_tag::include_header< Included >
 Crxcpp::replay_tag::include_header< Included >
 Crxcpp::retry_tag::include_header< Included >
 Crxcpp::sample_with_time_tag::include_header< Included >
 Crxcpp::scan_tag::include_header< Included >
 Crxcpp::sequence_equal_tag::include_header< Included >
 Crxcpp::skip_tag::include_header< Included >
 Crxcpp::skip_last_tag::include_header< Included >
 Crxcpp::skip_until_tag::include_header< Included >
 Crxcpp::start_with_tag::include_header< Included >
 Crxcpp::subscribe_on_tag::include_header< Included >
 Crxcpp::switch_if_empty_tag::include_header< Included >
 Crxcpp::switch_on_next_tag::include_header< Included >
 Crxcpp::take_tag::include_header< Included >
 Crxcpp::take_last_tag::include_header< Included >
 Crxcpp::take_while_tag::include_header< Included >
 Crxcpp::take_until_tag::include_header< Included >
 Crxcpp::tap_tag::include_header< Included >
 Crxcpp::timeout_tag::include_header< Included >
 Crxcpp::time_interval_tag::include_header< Included >
 Crxcpp::timestamp_tag::include_header< Included >
 Crxcpp::window_tag::include_header< Included >
 Crxcpp::window_with_time_tag::include_header< Included >
 Crxcpp::window_with_time_or_count_tag::include_header< Included >
 Crxcpp::window_toggle_tag::include_header< Included >
 Crxcpp::with_latest_from_tag::include_header< Included >
 Crxcpp::zip_tag::include_header< Included >
 Crxcpp::is_accumulate_function_for< T, Seed, Accumulator >
 Cis_base_of
 Crxcpp::is_connectable_observable< T >
 Cis_convertible
 Crxcpp::is_dynamic_connectable_observable< T >
 Crxcpp::is_dynamic_grouped_observable< T >
 Crxcpp::is_dynamic_observable< T >
 Crxcpp::is_dynamic_observer< T >
 Crxcpp::is_grouped_observable< T >
 Crxcpp::is_observer< T >
 Crxcpp::is_operator_factory_for< Source, Function >
 Crxcpp::is_schedulable< T >
 Crxcpp::is_scheduler< T >
 Crxcpp::sources::is_source< T >
 Crxcpp::is_subscriber< T >
 Crxcpp::is_subscription< T >
 Crxcpp::is_worker< T >
 Ccpplinq::iter_range< Iter >
 Ccpplinq::util::iter_to_cursor_category< Iter >
 Ccpplinq::util::iter_to_cursor_category_< size_t >
 Ccpplinq::util::iter_to_cursor_category_< 1 >
 Ccpplinq::util::iter_to_cursor_category_< 2 >
 Ccpplinq::util::iter_to_cursor_category_< 3 >
 Ccpplinq::util::iter_to_cursor_category_< 4 >
 Citerator
 Crxcpp::util::less
 Ccpplinq::util::less_or_equal_cursor_category< Cat1, Cat2 >
 Ccpplinq::util::less_or_equal_iterator_category< Cat1, Cat2 >
 Ccpplinq::linq_driver< Collection >
 Ccpplinq::linq_groupby< Collection, KeyFn, Compare >
 Ccpplinq::linq_select< Collection, Selector >
 Ccpplinq::linq_select_many< Container1, Fn, Fn2 >
 Ccpplinq::linq_skip< Collection >
 Ccpplinq::linq_take< Collection >
 Ccpplinq::linq_take_cursor< InnerCursor >
 Ccpplinq::linq_where< Collection, Predicate >
 Crxcpp::map_tag
 Ccpplinq::util::maybe< T >
 Ccpplinq::util::maybe< Cursor >
 Crxcpp::member_overload< Tag >
 Crxcpp::member_overload< all_tag >
 Crxcpp::member_overload< amb_tag >
 Crxcpp::member_overload< any_tag >
 Crxcpp::member_overload< average_tag >
 Crxcpp::member_overload< buffer_count_tag >
 Crxcpp::member_overload< buffer_with_time_or_count_tag >
 Crxcpp::member_overload< buffer_with_time_tag >
 Crxcpp::member_overload< combine_latest_tag >
 Crxcpp::member_overload< concat_map_tag >
 Crxcpp::member_overload< concat_tag >
 Crxcpp::member_overload< connect_forever_tag >
 Crxcpp::member_overload< contains_tag >
 Crxcpp::member_overload< debounce_tag >
 Crxcpp::member_overload< default_if_empty_tag >
 Crxcpp::member_overload< delay_tag >
 Crxcpp::member_overload< distinct_tag >
 Crxcpp::member_overload< distinct_until_changed_tag >
 Crxcpp::member_overload< element_at_tag >
 Crxcpp::member_overload< filter_tag >
 Crxcpp::member_overload< finally_tag >
 Crxcpp::member_overload< first_tag >
 Crxcpp::member_overload< flat_map_tag >
 Crxcpp::member_overload< group_by_tag >
 Crxcpp::member_overload< ignore_elements_tag >
 Crxcpp::member_overload< is_empty_tag >
 Crxcpp::member_overload< last_tag >
 Crxcpp::member_overload< map_tag >
 Crxcpp::member_overload< max_tag >
 Crxcpp::member_overload< merge_tag >
 Crxcpp::member_overload< min_tag >
 Crxcpp::member_overload< multicast_tag >
 Crxcpp::member_overload< observe_on_tag >
 Crxcpp::member_overload< on_error_resume_next_tag >
 Crxcpp::member_overload< pairwise_tag >
 Crxcpp::member_overload< publish_synchronized_tag >
 Crxcpp::member_overload< publish_tag >
 Crxcpp::member_overload< reduce_tag >
 Crxcpp::member_overload< ref_count_tag >
 Crxcpp::member_overload< repeat_tag >
 Crxcpp::member_overload< replay_tag >
 Crxcpp::member_overload< retry_tag >
 Crxcpp::member_overload< sample_with_time_tag >
 Crxcpp::member_overload< scan_tag >
 Crxcpp::member_overload< sequence_equal_tag >
 Crxcpp::member_overload< skip_last_tag >
 Crxcpp::member_overload< skip_tag >
 Crxcpp::member_overload< skip_until_tag >
 Crxcpp::member_overload< start_with_tag >
 Crxcpp::member_overload< subscribe_on_tag >
 Crxcpp::member_overload< sum_tag >
 Crxcpp::member_overload< switch_if_empty_tag >
 Crxcpp::member_overload< switch_on_next_tag >
 Crxcpp::member_overload< take_last_tag >
 Crxcpp::member_overload< take_tag >
 Crxcpp::member_overload< take_until_tag >
 Crxcpp::member_overload< take_while_tag >
 Crxcpp::member_overload< tap_tag >
 Crxcpp::member_overload< time_interval_tag >
 Crxcpp::member_overload< timeout_tag >
 Crxcpp::member_overload< timestamp_tag >
 Crxcpp::member_overload< window_tag >
 Crxcpp::member_overload< window_toggle_tag >
 Crxcpp::member_overload< window_with_time_or_count_tag >
 Crxcpp::member_overload< window_with_time_tag >
 Crxcpp::member_overload< with_latest_from_tag >
 Crxcpp::member_overload< zip_tag >
 Crxcpp::merge_tag
 Crxcpp::schedulers::test::messages< T >
 Ccpplinq::util::min_cursor_category< Cat1, Cat2, Cat3 >
 Crxcpp::multicast_tag
 Ccpplinq::noread_cursor_tag
 Crxcpp::notifications::notification< T >
 Crxcpp::observable< void, void >Typed as rxcpp::observable<>, this is a collection of factory methods that return an observable
 Crxcpp::observable_base< T >
 Crxcpp::observe_on_tag
 Crxcpp::observer_base< T >
 Crxcpp::on_error_resume_next_tag
 Ccpplinq::onepass_cursor_tag
 Crxcpp::operators::operator_base< T >
 Crxcpp::operators::operator_base< all_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< amb_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< any_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< bool >
 Crxcpp::operators::operator_base< buffer_count_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< buffer_with_time_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< buffer_with_time_or_count_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< combine_latest_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< concat_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< concat_map_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< connect_forever_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< debounce_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< delay_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< distinct_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< distinct_until_changed_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< element_at_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< filter_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< finally_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< flat_map_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< group_by_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< ignore_elements_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< lift_traits< ResultType, SourceOperator, Operator >::result_value_type >
 Crxcpp::operators::operator_base< map_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< merge_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< multicast_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< observe_on_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< on_error_resume_next_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< pairwise_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< publish_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< reduce_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< ref_count_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< repeat_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< replay_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< retry_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< rxu::decay_t< Seed > >
 Crxcpp::operators::operator_base< rxu::value_type_t< combine_latest_traits< Coordination, Selector, ObservableN... > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< concat_traits< Observable, CollectionSelector, ResultSelector, Coordination > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< flat_map_traits< Observable, CollectionSelector, ResultSelector, Coordination > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< reduce_traits< T, Observable, Accumulator, ResultSelector, Seed > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< rxu::decay_t< T > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< T > >
 Crxcpp::operators::operator_base< rxu::value_type_t< with_latest_from_traits< Coordination, Selector, ObservableN... > > >
 Crxcpp::operators::operator_base< rxu::value_type_t< zip_traits< Coordination, Selector, ObservableN... > > >
 Crxcpp::operators::operator_base< sample_with_time_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< scan_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< sequence_equal_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< skip_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< skip_last_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< skip_until_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< start_with_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< subscribe_on_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< switch_if_empty_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< switch_on_next_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< take_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< take_last_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< take_until_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< take_while_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< tap_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< time_interval_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< timeout_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< timestamp_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< window_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< window_toggle_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< window_with_time_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< window_with_time_or_count_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< with_latest_from_invalid_arguments< AN... > >
 Crxcpp::operators::operator_base< zip_invalid_arguments< AN... > >
 Crxcpp::operator_factory< Tag, AN >
 Crxcpp::pairwise_tag
 Crxcpp::util::plus
 Crxcpp::publish_tag
 Crxcpp::notifications::recorded< T >
 Crxcpp::schedulers::recurse
 Crxcpp::schedulers::recursed
 Crxcpp::schedulers::recursionRecursion is used by the scheduler to signal to each action whether tail recursion is allowed
 Crxcpp::reduce_tag
 Crxcpp::ref_count_tag
 Crxcpp::repeat_tag
 Crxcpp::subjects::replay< T, Coordination >
 Crxcpp::replay_tag
 Crxcpp::detail::resolve_observable< Selector, Default, SO >
 Crxcpp::detail::resolve_observable< Selector::value, Default, rxu::defer_type< SO, AN... > >
 Crxcpp::util::resolve_type< D >
 Crxcpp::util::resolve_type< defer_seed_type< Deferred, AN... > >
 Crxcpp::util::resolve_type< defer_type< Deferred, AN... > >
 Crxcpp::util::resolve_type< defer_value_type< Deferred, AN... > >
 Crxcpp::retry_tag
 Crxcpp::schedulers::run_loop
 Cruntime_error
 Crxcpp::sample_with_time_tag
 Crxcpp::scan_tag
 Crxcpp::schedulers::scheduler_base
 Crxcpp::sequence_equal_tag
 Crxcpp::skip_last_tag
 Crxcpp::skip_tag
 Crxcpp::skip_until_tag
 Crxcpp::sources::source_base< T >
 Crxcpp::sources::source_base< long >
 Crxcpp::sources::source_base< marble_type >
 Crxcpp::sources::source_base< rxu::value_type_t< defer_traits< ObservableFactory > > >
 Crxcpp::sources::source_base< rxu::value_type_t< iterate_traits< Collection > > >
 Crxcpp::sources::source_base< rxu::value_type_t< scope_traits< ResourceFactory, ObservableFactory > > >
 Crxcpp::schedulers::test::test_worker::start_traits< F >
 Crxcpp::start_with_tag
 Crxcpp::static_subscription< Unsubscribe >
 Crxcpp::subjects::subject< T >
 Crxcpp::subscribe_on_tag
 Crxcpp::notifications::subscription
 Crxcpp::subscription_base
 Crxcpp::switch_if_empty_tag
 Crxcpp::switch_on_next_tag
 Crxcpp::subjects::synchronize< T, Coordination >
 Crxcpp::tag_action
 Crxcpp::tag_coordination
 Crxcpp::tag_coordinator
 Crxcpp::tag_dynamic_observable
 Crxcpp::tag_dynamic_observer
 Crxcpp::util::defer_seed_type< Deferred, AN >::tag_not_valid
 Crxcpp::util::defer_trait< Deferred, AN >::tag_not_valid
 Crxcpp::util::defer_value_type< Deferred, AN >::tag_not_valid
 Crxcpp::is_accumulate_function_for< T, Seed, Accumulator >::tag_not_valid
 Crxcpp::util::defer_type< Deferred, AN >::tag_not_valid
 Crxcpp::tag_observable
 Crxcpp::tag_observer
 Crxcpp::operators::tag_operator
 Crxcpp::tag_schedulable
 Crxcpp::tag_scheduler
 Crxcpp::sources::tag_source
 Crxcpp::tag_subscriber
 Crxcpp::tag_subscription
 Crxcpp::util::defer_seed_type< Deferred, AN >::tag_valid< R >
 Crxcpp::util::defer_value_type< Deferred, AN >::tag_valid< R >
 Crxcpp::util::defer_trait< Deferred, AN >::tag_valid< R >
 Crxcpp::util::defer_type< Deferred, AN >::tag_valid< R >
 Crxcpp::tag_worker
 Crxcpp::take_last_tag
 Crxcpp::take_tag
 Crxcpp::take_until_tag
 Crxcpp::take_while_tag
 Crxcpp::tap_tag
 Crxcpp::time_interval_tag
 Crxcpp::timeout_tag
 Crxcpp::timestamp_tag
 Crxcpp::trace_id
 Crxcpp::trace_noop
 Crxcpp::trace_tag
 Ctrue_type
 Ctype
 Crxcpp::util::types< TN >
 Crxcpp::util::types_checked
 Crxcpp::util::types_checked_from< TN >
 Ccpplinq::use_default_iterator_operators
 Ccpplinq::util::value_ptr< T >
 Crxcpp::util::values< T, ValueN >
 Crxcpp::util::values_from< T, Remaining, Step, Cursor, ValueN >
 Crxcpp::util::values_from< T, 0, Step, Cursor, ValueN... >
 Crxcpp::schedulers::weak_worker
 Crxcpp::window_tag
 Crxcpp::window_toggle_tag
 Crxcpp::window_with_time_or_count_tag
 Crxcpp::window_with_time_tag
 Crxcpp::with_latest_from_tag
 Crxcpp::zip_tag