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 Index
a | b | c | d | e | f | g | i | l | m | n | o | p | r | s | t | u | v | w | z
  a  
filtered_hash< T, typename std::enable_if< std::is_integral< T >::value >::type > (rxcpp)    is_hashable (rxcpp)    member_overload< start_with_tag > (rxcpp)    source_base (rxcpp::sources)   
filtered_hash< T, typename std::enable_if< std::is_pointer< T >::value >::type > (rxcpp)    is_hashable< T, typename rxu::types_checked_from< typename filtered_hash< T >::result_type, typename filtered_hash< T >::argument_type, typename std::result_of< filtered_hash< T >(T)>::type >::type > (rxcpp)    member_overload< subscribe_on_tag > (rxcpp)    test::test_worker::start_traits (rxcpp::schedulers)   
action (rxcpp::schedulers)    finally_tag (rxcpp)    is_observable (rxcpp)    member_overload< sum_tag > (rxcpp)    start_with_tag (rxcpp)   
action_base (rxcpp::schedulers)    first_tag (rxcpp)    is_observer (rxcpp)    member_overload< switch_if_empty_tag > (rxcpp)    static_subscription (rxcpp)   
all_tag (rxcpp)    flat_map_tag (rxcpp)    is_operator (rxcpp::operators)    member_overload< switch_on_next_tag > (rxcpp)    subject (rxcpp::subjects)   
all_true (rxcpp::util)    forward_cursor_tag (cpplinq)    is_operator_factory_for (rxcpp)    member_overload< take_last_tag > (rxcpp)    subscribe_on_tag (rxcpp)   
all_true< B > (rxcpp::util)   
  g  
is_schedulable (rxcpp)    member_overload< take_tag > (rxcpp)    subscriber (rxcpp)   
all_true< B, BN... > (rxcpp::util)    is_scheduler (rxcpp)    member_overload< take_until_tag > (rxcpp)    subscriber_base (rxcpp)   
all_true_type (rxcpp::util)    coordinator::get (rxcpp)    is_source (rxcpp::sources)    member_overload< take_while_tag > (rxcpp)    subscription (rxcpp::notifications)   
all_true_type< B > (rxcpp::util)    group (cpplinq)    is_string (rxcpp::util)    member_overload< tap_tag > (rxcpp)    subscription (rxcpp)   
all_true_type< B, BN... > (rxcpp::util)    group_by_tag (rxcpp)    is_string< T, typename types_checked_from< typename T::value_type, typename T::traits_type, typename T::allocator_type >::type > (rxcpp::util)    member_overload< time_interval_tag > (rxcpp)    subscription_base (rxcpp)   
all_values_true (rxcpp::util)    grouped_observable (rxcpp)    is_subscriber (rxcpp)    member_overload< timeout_tag > (rxcpp)    sum_tag (rxcpp)   
amb_tag (rxcpp)   
  i  
is_subscription (rxcpp)    member_overload< timestamp_tag > (rxcpp)    switch_if_empty_tag (rxcpp)   
any_tag (rxcpp)    is_worker (rxcpp)    member_overload< window_tag > (rxcpp)    switch_on_next_tag (rxcpp)   
any_value_true (rxcpp::util)    identity (cpplinq::util)    iter_cursor (cpplinq)    member_overload< window_toggle_tag > (rxcpp)    synchronize (rxcpp::subjects)   
average_tag (rxcpp)    identity_for (rxcpp)    iter_range (cpplinq)    member_overload< window_with_time_or_count_tag > (rxcpp)    synchronize_in_one_worker (rxcpp)   
  b  
identity_observable (rxcpp)    iter_to_cursor_category (cpplinq::util)    member_overload< window_with_time_tag > (rxcpp)   
  t  
identity_one_worker (rxcpp)    iter_to_cursor_category_ (cpplinq::util)    member_overload< with_latest_from_tag > (rxcpp)   
behavior (rxcpp::subjects)    ignore_elements_tag (rxcpp)    iter_to_cursor_category_< 1 > (cpplinq::util)    member_overload< zip_tag > (rxcpp)    tag_action (rxcpp)   
bidirectional_cursor_tag (cpplinq)    immediate (rxcpp::schedulers)    iter_to_cursor_category_< 2 > (cpplinq::util)    merge_delay_error_tag (rxcpp)    tag_connectable_observable (rxcpp)   
blocking_observable (rxcpp)    amb_tag::include_header (rxcpp)    iter_to_cursor_category_< 3 > (cpplinq::util)    merge_tag (rxcpp)    tag_coordination (rxcpp)   
buffer_count_tag (rxcpp)    all_tag::include_header (rxcpp)    iter_to_cursor_category_< 4 > (cpplinq::util)    test::messages (rxcpp::schedulers)    tag_coordinator (rxcpp)   
buffer_with_time_or_count_tag (rxcpp)    any_tag::include_header (rxcpp)   
  l  
min_cursor_category (cpplinq::util)    tag_dynamic_connectable_observable (rxcpp)   
buffer_with_time_tag (rxcpp)    buffer_count_tag::include_header (rxcpp)    min_cursor_category< Cat1, Cat2 > (cpplinq::util)    tag_dynamic_grouped_observable (rxcpp)   
  c  
buffer_with_time_tag::include_header (rxcpp)    last_tag (rxcpp)    min_iterator_category (cpplinq::util)    tag_dynamic_observable (rxcpp)   
buffer_with_time_or_count_tag::include_header (rxcpp)    less (rxcpp::util)    min_tag (rxcpp)    tag_dynamic_observer (rxcpp)   
collection_tag (cpplinq)    combine_latest_tag::include_header (rxcpp)    less_or_equal_cursor_category (cpplinq::util)    multicast_tag (rxcpp)    tag_grouped_observable (rxcpp)   
combine_latest_tag (rxcpp)    concat_tag::include_header (rxcpp)    less_or_equal_iterator_category (cpplinq::util)   
  n  
defer_seed_type::tag_not_valid (rxcpp::util)   
composite_exception (rxcpp)    concat_map_tag::include_header (rxcpp)    linq_driver (cpplinq)    is_accumulate_function_for::tag_not_valid (rxcpp)   
composite_subscription (rxcpp)    connect_forever_tag::include_header (rxcpp)    linq_groupby (cpplinq)    negation (rxcpp::util)    defer_value_type::tag_not_valid (rxcpp::util)   
concat_map_tag (rxcpp)    debounce_tag::include_header (rxcpp)    linq_select (cpplinq)    new_thread (rxcpp::schedulers)    defer_type::tag_not_valid (rxcpp::util)   
concat_tag (rxcpp)    delay_tag::include_header (rxcpp)    linq_select_many (cpplinq)    noread_cursor_tag (cpplinq)    defer_trait::tag_not_valid (rxcpp::util)   
connect_forever_tag (rxcpp)    distinct_tag::include_header (rxcpp)    linq_skip (cpplinq)    notification (rxcpp::notifications)    tag_observable (rxcpp)   
connectable_observable (rxcpp)    distinct_until_changed_tag::include_header (rxcpp)    linq_take (cpplinq)   
  o  
tag_observer (rxcpp)   
container_interface (cpplinq)    element_at_tag::include_header (rxcpp)    linq_take_cursor (cpplinq)    tag_operator (rxcpp::operators)   
container_range (cpplinq)    filter_tag::include_header (rxcpp)    linq_where (cpplinq)    observable (rxcpp)    tag_schedulable (rxcpp)   
container_traits (cpplinq::util)    finally_tag::include_header (rxcpp)   
  m  
observable< void, void > (rxcpp)    tag_scheduler (rxcpp)   
container_traits< const Container > (cpplinq::util)    flat_map_tag::include_header (rxcpp)    observable_base (rxcpp)    tag_source (rxcpp::sources)   
container_traits< Container & > (cpplinq::util)    group_by_tag::include_header (rxcpp)    map_tag (rxcpp)    observe_on_one_worker (rxcpp)    tag_subscriber (rxcpp)   
contains_tag (rxcpp)    ignore_elements_tag::include_header (rxcpp)    max_tag (rxcpp)    observe_on_tag (rxcpp)    tag_subscription (rxcpp)   
coordination_base (rxcpp)    map_tag::include_header (rxcpp)    maybe (cpplinq::util)    observer (rxcpp)    defer_value_type::tag_valid (rxcpp::util)   
coordinator (rxcpp)    merge_tag::include_header (rxcpp)    member_overload (rxcpp)    observer< T, void, void, void, void > (rxcpp)    defer_trait::tag_valid (rxcpp::util)   
coordinator_base (rxcpp)    merge_delay_error_tag::include_header (rxcpp)    member_overload< all_tag > (rxcpp)    observer_base (rxcpp)    defer_seed_type::tag_valid (rxcpp::util)   
count (rxcpp::util)    multicast_tag::include_header (rxcpp)    member_overload< amb_tag > (rxcpp)    on_error_resume_next_tag (rxcpp)    defer_type::tag_valid (rxcpp::util)   
current_thread (rxcpp::schedulers)    observe_on_tag::include_header (rxcpp)    member_overload< any_tag > (rxcpp)    onepass_cursor_tag (cpplinq)    tag_worker (rxcpp)   
linq_groupby::cursor (cpplinq)    on_error_resume_next_tag::include_header (rxcpp)    member_overload< average_tag > (rxcpp)    operator_base (rxcpp::operators)    take_last_tag (rxcpp)   
linq_select::cursor (cpplinq)    reduce_tag::include_header (rxcpp)    member_overload< buffer_count_tag > (rxcpp)    operator_factory (rxcpp)    take_tag (rxcpp)   
linq_where::cursor (cpplinq)    ref_count_tag::include_header (rxcpp)    member_overload< buffer_with_time_or_count_tag > (rxcpp)   
  p  
take_until_tag (rxcpp)   
linq_select_many::cursor (cpplinq)    pairwise_tag::include_header (rxcpp)    member_overload< buffer_with_time_tag > (rxcpp)    take_while_tag (rxcpp)   
cursor_interface (cpplinq)    publish_tag::include_header (rxcpp)    member_overload< combine_latest_tag > (rxcpp)    pairwise_tag (rxcpp)    tap_tag (rxcpp)   
cursor_iterator (cpplinq)    repeat_tag::include_header (rxcpp)    member_overload< concat_map_tag > (rxcpp)    plus (rxcpp::util)    test (rxcpp::schedulers)   
cursor_type (cpplinq::util)    replay_tag::include_header (rxcpp)    member_overload< concat_tag > (rxcpp)    publish_synchronized_tag (rxcpp)    test::test_worker (rxcpp::schedulers)   
  d  
retry_tag::include_header (rxcpp)    member_overload< connect_forever_tag > (rxcpp)    publish_tag (rxcpp)    testable_observable (rxcpp::test)   
sample_with_time_tag::include_header (rxcpp)    member_overload< contains_tag > (rxcpp)   
  r  
testable_observer (rxcpp::test)   
debounce_tag (rxcpp)    scan_tag::include_header (rxcpp)    member_overload< debounce_tag > (rxcpp)    time_interval_tag (rxcpp)   
default_equality (cpplinq)    sequence_equal_tag::include_header (rxcpp)    member_overload< default_if_empty_tag > (rxcpp)    random_access_cursor_tag (cpplinq)    timeout_error (rxcpp)   
default_if_empty_tag (rxcpp)    skip_tag::include_header (rxcpp)    member_overload< delay_tag > (rxcpp)    readonly_cursor_tag (cpplinq)    timeout_tag (rxcpp)   
default_less (cpplinq)    skip_while_tag::include_header (rxcpp)    member_overload< distinct_tag > (rxcpp)    readwrite_cursor_tag (cpplinq)    timestamp_tag (rxcpp)   
defer_observable (rxcpp)    skip_last_tag::include_header (rxcpp)    member_overload< distinct_until_changed_tag > (rxcpp)    recorded (rxcpp::notifications)    trace_id (rxcpp)   
defer_seed_type (rxcpp::util)    skip_until_tag::include_header (rxcpp)    member_overload< element_at_tag > (rxcpp)    recurse (rxcpp::schedulers)    trace_noop (rxcpp)   
defer_trait (rxcpp::util)    start_with_tag::include_header (rxcpp)    member_overload< exists_tag > (rxcpp)    recursed (rxcpp::schedulers)    trace_tag (rxcpp)   
defer_type (rxcpp::util)    subscribe_on_tag::include_header (rxcpp)    member_overload< filter_tag > (rxcpp)    recursion (rxcpp::schedulers)    types (rxcpp::util)   
defer_value_type (rxcpp::util)    switch_if_empty_tag::include_header (rxcpp)    member_overload< finally_tag > (rxcpp)    reduce_tag (rxcpp)    types_checked (rxcpp::util)   
delay_tag (rxcpp)    switch_on_next_tag::include_header (rxcpp)    member_overload< first_tag > (rxcpp)    ref_count_tag (rxcpp)    types_checked_from (rxcpp::util)   
delayed_type (rxcpp)    take_tag::include_header (rxcpp)    member_overload< flat_map_tag > (rxcpp)    repeat_tag (rxcpp)   
  u  
distinct_tag (rxcpp)    take_last_tag::include_header (rxcpp)    member_overload< group_by_tag > (rxcpp)    replay (rxcpp::subjects)   
distinct_until_changed_tag (rxcpp)    take_while_tag::include_header (rxcpp)    member_overload< ignore_elements_tag > (rxcpp)    replay_tag (rxcpp)    use_default_iterator_operators (cpplinq)   
dynamic_collection (cpplinq)    take_until_tag::include_header (rxcpp)    member_overload< is_empty_tag > (rxcpp)    resolve_type (rxcpp::util)   
  v  
dynamic_connectable_observable (rxcpp)    tap_tag::include_header (rxcpp)    member_overload< last_tag > (rxcpp)    resolve_type< defer_seed_type< Deferred, AN... > > (rxcpp::util)   
dynamic_cursor (cpplinq)    timeout_tag::include_header (rxcpp)    member_overload< map_tag > (rxcpp)    resolve_type< defer_type< Deferred, AN... > > (rxcpp::util)    value_ptr (cpplinq::util)   
dynamic_grouped_observable (rxcpp)    time_interval_tag::include_header (rxcpp)    member_overload< max_tag > (rxcpp)    resolve_type< defer_value_type< Deferred, AN... > > (rxcpp::util)    value_type_from (rxcpp::util)   
dynamic_observable (rxcpp)    timestamp_tag::include_header (rxcpp)    member_overload< merge_delay_error_tag > (rxcpp)    resource (rxcpp)    value_type_from< T, typename types_checked_from< value_type_t< T > >::type > (rxcpp::util)   
  e  
window_tag::include_header (rxcpp)    member_overload< merge_tag > (rxcpp)    ret (rxcpp::util)    values (rxcpp::util)   
window_with_time_tag::include_header (rxcpp)    member_overload< min_tag > (rxcpp)    retry_tag (rxcpp)    values_from (rxcpp::util)   
element_at_tag (rxcpp)    window_with_time_or_count_tag::include_header (rxcpp)    member_overload< multicast_tag > (rxcpp)    run_loop (rxcpp::schedulers)    values_from< T, 0, Step, Cursor, ValueN... > (rxcpp::util)   
empty_error (rxcpp)    window_toggle_tag::include_header (rxcpp)    member_overload< observe_on_tag > (rxcpp)    run_loop_scheduler (rxcpp::schedulers)    virtual_time (rxcpp::schedulers)   
equal_to (rxcpp::util)    with_latest_from_tag::include_header (rxcpp)    member_overload< on_error_resume_next_tag > (rxcpp)   
  s  
  w  
equal_to< void > (rxcpp::util)    zip_tag::include_header (rxcpp)    member_overload< pairwise_tag > (rxcpp)   
event_loop (rxcpp::schedulers)    is_accumulate_function_for (rxcpp)    member_overload< publish_synchronized_tag > (rxcpp)    same_worker (rxcpp::schedulers)    weak_worker (rxcpp::schedulers)   
exists_tag (rxcpp)    is_action (rxcpp)    member_overload< publish_tag > (rxcpp)    sample_with_time_tag (rxcpp)    window_tag (rxcpp)   
expand_observable_tags (rxcpp)    is_action< T, typename rxu::types_checked_from< typename T::action_tag >::type > (rxcpp)    member_overload< reduce_tag > (rxcpp)    scan_tag (rxcpp)    window_toggle_tag (rxcpp)   
expand_observable_tags< rxu::types< ObservableN... >, rxu::types_checked_t< typename ObservableN::observable_tag... > > (rxcpp)    is_connectable_observable (rxcpp)    member_overload< ref_count_tag > (rxcpp)    schedulable (rxcpp::schedulers)    window_with_time_or_count_tag (rxcpp)   
expand_value_types (rxcpp::util)    is_coordination (rxcpp)    member_overload< repeat_tag > (rxcpp)    schedulable_base (rxcpp::schedulers)    window_with_time_tag (rxcpp)   
expand_value_types< types< TN... >, types_checked_t< typename std::decay< TN >::type::value_type... > > (rxcpp::util)    is_coordinator (rxcpp)    member_overload< replay_tag > (rxcpp)    scheduler (rxcpp::schedulers)    with_latest_from_tag (rxcpp)   
  f  
is_coordinator< T, typename rxu::types_checked_from< typename T::coordinator_tag >::type > (rxcpp)    member_overload< retry_tag > (rxcpp)    scheduler_base (rxcpp::schedulers)    worker (rxcpp::schedulers)   
is_duration (rxcpp::util)    member_overload< sample_with_time_tag > (rxcpp)    scheduler_interface (rxcpp::schedulers)    worker_base (rxcpp::schedulers)   
filter_tag (rxcpp)    is_dynamic_connectable_observable (rxcpp)    member_overload< scan_tag > (rxcpp)    sequence_equal_tag (rxcpp)    worker_interface (rxcpp::schedulers)   
filtered_hash (rxcpp)    is_dynamic_grouped_observable (rxcpp)    member_overload< sequence_equal_tag > (rxcpp)    serialize_one_worker (rxcpp)   
  z  
filtered_hash< T, typename std::enable_if< rxu::is_string< T >::value >::type > (rxcpp)    is_dynamic_observable (rxcpp)    member_overload< skip_last_tag > (rxcpp)    skip_last_tag (rxcpp)   
filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::duration< typename T::rep, typename T::period > >::value >::type > (rxcpp)    is_dynamic_observer (rxcpp)    member_overload< skip_tag > (rxcpp)    skip_tag (rxcpp)    zip_tag (rxcpp)   
filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::time_point< typename T::clock, typename T::duration > >::value >::type > (rxcpp)    is_empty_tag (rxcpp)    member_overload< skip_until_tag > (rxcpp)    skip_until_tag (rxcpp)   
filtered_hash< T, typename std::enable_if< std::is_enum< T >::value >::type > (rxcpp)    is_grouped_observable (rxcpp)    member_overload< skip_while_tag > (rxcpp)    skip_while_tag (rxcpp)   
a | b | c | d | e | f | g | i | l | m | n | o | p | r | s | t | u | v | w | z