| Crpp::schedulers::details::schedulable_base::advanced_call | |
| Crpp::operators::details::as_blocking_t | |
| Crpp::details::auto_dispose_wrapper< TDisposable > | |
| Crppgrpc::details::base_reader< TData > | |
| ▼Crppgrpc::details::base_reader< Request > | |
| Crppgrpc::server_bidi_reactor< Request, Response > | RPP's based implementation for grpc server bidirectional reactor |
| Crppgrpc::server_read_reactor< Request > | RPP's based implementation for grpc server read reactor |
| ▼Crppgrpc::details::base_reader< Response > | |
| Crppgrpc::client_bidi_reactor< Request, Response > | RPP's based implementation for grpc client bidirectional reactor |
| Crppgrpc::client_read_reactor< Response > | RPP's based implementation for grpc client read reactor |
| ▼Crppgrpc::details::base_reader< rpp::utils::none > | |
| Crppgrpc::client_write_reactor< Request > | RPP's based implementation for grpc client write reactor |
| Crppgrpc::server_write_reactor< Response > | RPP's based implementation for grpc server write reactor |
| Crppgrpc::details::base_writer< TData > | |
| ▼Crppgrpc::details::base_writer< Request > | |
| Crppgrpc::client_bidi_reactor< Request, Response > | RPP's based implementation for grpc client bidirectional reactor |
| Crppgrpc::client_write_reactor< Request > | RPP's based implementation for grpc client write reactor |
| ▼Crppgrpc::details::base_writer< Response > | |
| Crppgrpc::server_bidi_reactor< Request, Response > | RPP's based implementation for grpc server bidirectional reactor |
| Crppgrpc::server_write_reactor< Response > | RPP's based implementation for grpc server write reactor |
| ▼CBaseInterface | |
| ▼Crpp::details::base_disposable_impl< BaseInterface > | |
| Crpp::callback_disposable< Fn > | Disposable invokes underlying callable on disposing |
| Crpp::details::observables::blocking_disposable | |
| Crpp::operators::details::concat_disposable< TObservable, TObserver > | |
| Crpp::operators::details::switch_on_next_state_t< TObserver > | |
| Crpp::subjects::details::behavior_subject_base< Type, Serialized > | |
| ▼Crpp::subjects::details::behavior_subject_base< Type, false > | |
| Crpp::subjects::behavior_subject< Type > | Same as rpp::subjects::publish_subject but keeps last value (or default) and emits it to newly subscribed observer |
| ▼Crpp::subjects::details::behavior_subject_base< Type, true > | |
| Crpp::subjects::serialized_behavior_subject< Type > | Same as rpp::subjects::behavior_subject but on_next/on_error/on_completed calls are serialized via mutex |
| Crpp::details::observables::blocking_strategy< Type, Strategy > | |
| Crpp::operators::details::buffer_observer_strategy< TObserver > | |
| ▼CTestService::CallbackService | |
| Cserver | |
| Crpp::details::observables::chain< TStrategy, TStrategies > | |
| Crpp::details::observables::chain< TStrategy > | |
| ▼Cgrpc::ClientBidiReactor | |
| Crppgrpc::client_bidi_reactor< Request, Response > | RPP's based implementation for grpc client bidirectional reactor |
| ▼Cgrpc::ClientReadReactor | |
| Crppgrpc::client_read_reactor< Response > | RPP's based implementation for grpc client read reactor |
| ▼Cgrpc::ClientWriteReactor | |
| Crppgrpc::client_write_reactor< Request > | RPP's based implementation for grpc client write reactor |
| Crpp::operators::details::combining_observer_strategy< TDisposable > | |
| ▼Crpp::operators::details::combining_observer_strategy< combine_latest_disposable< Observer, TSelector, Args... > > | |
| Crpp::operators::details::combine_latest_observer_strategy< I, Observer, TSelector, Args > | |
| ▼Crpp::operators::details::combining_observer_strategy< zip_disposable< Observer, TSelector, Args... > > | |
| Crpp::operators::details::zip_observer_strategy< I, Observer, TSelector, Args > | |
| Crpp::operators::details::combining_operator_t< TDisposable, TStrategy, TSelector, TObservables > | |
| ▼Crpp::operators::details::combining_operator_t< combine_latest_disposable, combine_latest_observer_strategy, TSelector, TObservables... > | |
| Crpp::operators::details::combine_latest_t< TSelector, TObservables > | |
| ▼Crpp::operators::details::combining_operator_t< zip_disposable, zip_observer_strategy, TSelector, TObservables... > | |
| Crpp::operators::details::zip_t< TSelector, TObservables > | |
| Crpp::subjects::details::completed | |
| Crpp::schedulers::computational | Scheduler owning static thread pool of workers and using "some" thread from this pool on create_worker call |
| Crpp::operators::details::concat_inner_observer_strategy< TObservable, TObserver > | |
| Crpp::operators::details::concat_observer_strategy< TObservable, TObserver > | |
| Crpp::details::concat_source_observer_strategy< TObserver, PackedContainer > | |
| Crpp::details::concat_strategy< PackedContainer > | |
| Crpp::connectable_observable< OriginalObservable, Subject > | Extension over raw observable with ability to be manually connected at any time or ref_counting (sharing same observable between multiple observers) |
| Crpp::utils::convertible_to_any | |
| Crpp::details::create_strategy< Type, OnSubscribe > | |
| Crpp::schedulers::current_thread | Schedules execution of schedulables via queueing tasks to the caller thread with priority to time_point and order |
| Crpp::operators::details::debounce_disposable_wrapper< Observer, Worker, Container > | |
| Crpp::operators::details::debounce_observer_strategy< Observer, Worker, Container > | |
| Crpp::operators::details::debounce_t< Scheduler > | |
| Crpp::details::defer_strategy< Factory > | |
| Crpp::operators::details::delay_disposable_wrapper< Observer, Worker, Container > | |
| Crpp::schedulers::delay_from_now | Timepoint of next execution would be calculcated from NOW timpoint (time of returning from schedulable) |
| Crpp::schedulers::delay_from_this_timepoint | Timepoint of next execution would be calculcated from timepoint of current scheduling |
| Crpp::operators::details::delay_observer_strategy< Observer, Worker, Container, ClearOnError > | |
| Crpp::operators::details::delay_t< Scheduler, ClearOnError > | |
| Crpp::schedulers::delay_to | Provide timepoint of next execution explicitly |
| ▼Crpp::details::disposable_wrapper_base | |
| Crpp::disposable_wrapper_impl< behavior_state > | |
| Crpp::disposable_wrapper_impl< rpp::subjects::details::subject_state< Type, Serialized > > | |
| Crpp::disposable_wrapper_impl< replay_state > | |
| Crpp::disposable_wrapper_impl< interface_composite_disposable > | |
| Crpp::disposable_wrapper_impl< rpp::refcount_disposable > | |
| Crpp::disposable_wrapper_impl< rpp::subjects::details::subject_state< Type, false > > | |
| Crpp::disposable_wrapper_impl< interface_disposable > | |
| Crpp::disposable_wrapper_impl< TDisposable > | Main RPP wrapper over disposables |
| Crpp::subjects::details::disposed | |
| Crpp::operators::details::distinct_observer_strategy< Type, TObserver > | |
| Crpp::operators::details::distinct_until_changed_observer_strategy< Type, TObserver, EqualityFn > | |
| Crpp::details::disposables::dynamic_disposables_container | |
| Crpp::details::observables::dynamic_disposables_strategy | |
| Crpp::details::observables::dynamic_strategy< Type > | |
| Crpp::details::observers::dynamic_strategy< Type > | |
| Crpp::operators::details::element_at_observer_strategy< TObserver > | |
| Crpp::operators::details::emission< T > | |
| Crpp::utils::empty_function_any_by_lvalue_t | |
| Crpp::utils::empty_function_any_t | |
| Crpp::utils::empty_function_t< Types > | |
| Crpp::details::empty_strategy< Type > | |
| Crpp::details::enable_wrapper_from_this< TStrategy > | |
| ▼Crpp::details::enable_wrapper_from_this< concat_disposable< TObservable, TObserver > > | |
| Crpp::operators::details::concat_disposable< TObservable, TObserver > | |
| ▼Crpp::details::enable_wrapper_from_this< debounce_disposable< Observer, Worker, Container > > | |
| Crpp::operators::details::debounce_disposable< Observer, Worker, Container > | |
| ▼Crpp::details::enable_wrapper_from_this< refcount_disposable > | |
| Crpp::refcount_disposable | |
| ▼Crpp::details::enable_wrapper_from_this< refocunt_disposable_inner > | |
| Crpp::details::refocunt_disposable_inner | |
| ▼Crpp::details::enable_wrapper_from_this< subject_state< Type, Serialized > > | |
| Crpp::subjects::details::subject_state< Type, Serialized > | |
| Crpp::utils::equal_to | |
| Crpp::details::error_strategy< Type > | |
| Crpp::schedulers::details::fake_schedulable_handler | |
| Crpp::details::observables::fake_strategy< Type > | |
| Crpp::details::observers::fake_strategy | |
| ▼Cstd::false_type | |
| Crpp::schedulers::constraint::details::is_worker< T > | |
| Crpp::utils::is_not_template_callable_t< T, typename > | |
| Crpp::operators::details::filter_observer_strategy< TObserver, Fn > | |
| Crpp::utils::finally_action< Fn > | Calls passed function during destruction |
| Crpp::operators::details::finally_t< LastFn > | |
| Crpp::operators::details::first_observer_strategy< TObserver > | |
| Crpp::details::observables::fixed_disposables_strategy< Count > | |
| Crpp::operators::details::flat_map_t< Fn > | |
| Crpp::operators::details::forwarding_subject< Type > | |
| Crpp::details::from_callable_invoke | |
| Crpp::details::from_iterable_schedulable | |
| Crpp::details::from_iterable_strategy< PackedContainer, TScheduler > | |
| Crppqt::details::from_signal_on_event< Args > | |
| Crppqt::details::from_signal_on_event< Arg > | |
| Crppqt::details::from_signal_on_event<> | |
| Crpp::utils::function_traits< T > | |
| Crpp::utils::function_traits< R(*)()> | |
| ▼Crpp::utils::function_traits< R(*)(Args...)> | |
| Crpp::utils::function_traits< R(T::*)(Args...) const > | |
| Crpp::utils::function_traits< R(T::*)(Args...)> | |
| Crpp::operators::details::group_by_inner_observer_strategy< TObserver > | |
| Crpp::operators::details::group_by_observable_strategy< T > | |
| Crpp::operators::details::group_by_observer_strategy< T, TObserver, KeySelector, ValueSelector, KeyComparator > | |
| Crpp::schedulers::immediate | Immediately calls provided schedulable or waits for time_point (in the caller-thread) |
| Crpp::operators::details::infinite_repeat_t | |
| Crpp::utils::infinite_repeated_container< T > | |
| ▼Crpp::interface_disposable | Interface of disposable |
| ▼Crpp::interface_composite_disposable | |
| ▼Crpp::composite_disposable_impl< rpp::details::disposables::default_disposables_container > | |
| ▼Crpp::composite_disposable | Disposable which can keep some other sub-disposables. When this root disposable is disposed, then all sub-disposables would be disposed too |
| Crpp::details::concat_state_t< TObserver, PackedContainer > | |
| Crpp::details::refocunt_disposable_inner | |
| ▼Crpp::operators::details::combining_disposable< Observer > | |
| Crpp::operators::details::combine_latest_disposable< Observer, TSelector, Args > | |
| Crpp::operators::details::zip_disposable< Observer, TSelector, Args > | |
| Crpp::operators::details::merge_disposable< TObserver > | |
| Crpp::operators::details::on_error_resume_next_disposable< TObserver > | |
| Crpp::operators::details::retry_state_t< TObserver, Observable > | |
| Crpp::operators::details::retry_when_state< TObserver, TObservable, TNotifier > | |
| Crpp::operators::details::take_until_disposable< TObserver > | |
| Crpp::operators::details::with_latest_from_disposable< Observer, TSelector, RestArgs > | |
| Crpp::refcount_disposable | |
| Crpp::subjects::details::subject_state< Type, Serialized > | |
| ▼Crpp::composite_disposable_impl< Container > | Disposable which can keep some other sub-disposables. When this root disposable is disposed, then all sub-disposables would be disposed too |
| Crpp::operators::details::debounce_disposable< Observer, Worker, Container > | |
| Crpp::operators::details::delay_disposable< Observer, Worker, Container > | |
| Crpp::operators::details::timeout_disposable< TObserver, TFallbackObservable, Container > | |
| Crpp::details::interval_schedulable | |
| Crpp::details::interval_strategy< TScheduler, TimePointOrDuration > | |
| Crpp::schedulers::current_thread::is_queue_is_empty | |
| Crpp::utils::infinite_repeated_container< T >::iterator | |
| Crpp::utils::repeated_container< T >::iterator | |
| Crpp::details::observers::lambda_strategy< Type, OnNext, OnError, OnCompleted > | |
| Crpp::operators::details::last_observer_strategy< Type, TObserver > | |
| Crpp::utils::less | |
| Crpp::operators::details::lift_operator< Operator, TArgs > | |
| ▼Crpp::operators::details::lift_operator< buffer_t, size_t > | |
| Crpp::operators::details::buffer_t | |
| ▼Crpp::operators::details::lift_operator< concat_t > | |
| Crpp::operators::details::concat_t | |
| ▼Crpp::operators::details::lift_operator< distinct_t > | |
| Crpp::operators::details::distinct_t | |
| ▼Crpp::operators::details::lift_operator< distinct_until_changed_t< EqualityFn >, EqualityFn > | |
| Crpp::operators::details::distinct_until_changed_t< EqualityFn > | |
| ▼Crpp::operators::details::lift_operator< element_at_t, size_t > | |
| Crpp::operators::details::element_at_t | |
| ▼Crpp::operators::details::lift_operator< filter_t< Fn >, Fn > | |
| Crpp::operators::details::filter_t< Fn > | |
| ▼Crpp::operators::details::lift_operator< first_t > | |
| Crpp::operators::details::first_t | |
| ▼Crpp::operators::details::lift_operator< group_by_t< KeySelector, ValueSelector, KeyComparator >, KeySelector, ValueSelector, KeyComparator > | |
| Crpp::operators::details::group_by_t< KeySelector, ValueSelector, KeyComparator > | |
| ▼Crpp::operators::details::lift_operator< last_t > | |
| Crpp::operators::details::last_t | |
| ▼Crpp::operators::details::lift_operator< map_t< Fn >, Fn > | |
| Crpp::operators::details::map_t< Fn > | |
| ▼Crpp::operators::details::lift_operator< merge_t > | |
| Crpp::operators::details::merge_t | |
| ▼Crpp::operators::details::lift_operator< on_error_resume_next_t< Selector >, Selector > | |
| Crpp::operators::details::on_error_resume_next_t< Selector > | |
| ▼Crpp::operators::details::lift_operator< reduce_no_seed_t< Accumulator >, Accumulator > | |
| Crpp::operators::details::reduce_no_seed_t< Accumulator > | |
| ▼Crpp::operators::details::lift_operator< reduce_t< Seed, Accumulator >, Seed, Accumulator > | |
| Crpp::operators::details::reduce_t< Seed, Accumulator > | |
| ▼Crpp::operators::details::lift_operator< scan_no_seed_t< Fn >, Fn > | |
| Crpp::operators::details::scan_no_seed_t< Fn > | |
| ▼Crpp::operators::details::lift_operator< scan_t< InitialValue, Fn >, InitialValue, Fn > | |
| Crpp::operators::details::scan_t< InitialValue, Fn > | |
| ▼Crpp::operators::details::lift_operator< skip_t, size_t > | |
| Crpp::operators::details::skip_t | |
| ▼Crpp::operators::details::lift_operator< switch_on_next_t > | |
| Crpp::operators::details::switch_on_next_t | |
| ▼Crpp::operators::details::lift_operator< take_last_t, size_t > | |
| Crpp::operators::details::take_last_t | |
| ▼Crpp::operators::details::lift_operator< take_t, size_t > | |
| Crpp::operators::details::take_t | |
| ▼Crpp::operators::details::lift_operator< take_while_t< Fn >, Fn > | |
| Crpp::operators::details::take_while_t< Fn > | |
| ▼Crpp::operators::details::lift_operator< tap_t< OnNext, OnError, OnCompleted >, OnNext, OnError, OnCompleted > | |
| Crpp::operators::details::tap_t< OnNext, OnError, OnCompleted > | |
| ▼Crpp::operators::details::lift_operator< throttle_t< Scheduler >, rpp::schedulers::duration > | |
| Crpp::operators::details::throttle_t< Scheduler > | |
| ▼Crpp::operators::details::lift_operator< window_t, size_t > | |
| Crpp::operators::details::window_t | |
| ▼Crpp::operators::details::lift_operator< window_toggle_t< TOpeningsObservable, TClosingsSelectorFn >, TOpeningsObservable, TClosingsSelectorFn > | |
| Crpp::operators::details::window_toggle_t< TOpeningsObservable, TClosingsSelectorFn > | |
| Crpp::details::observers::local_disposables_strategy< DisposableContainer > | |
| Crppqt::schedulers::main_thread_scheduler | Schedule provided schedulables to main GUI QT thread (where QApplication placed) |
| Crpp::details::observables::make_chain< New, Old > | |
| Crpp::details::observables::make_chain< New, chain< Args... > > | |
| Crpp::operators::details::map_observer_strategy< TObserver, Fn > | |
| ▼Crpp::operators::details::merge_observer_base_strategy< TObserver > | |
| Crpp::operators::details::merge_observer_inner_strategy< TObserver > | |
| Crpp::operators::details::merge_observer_strategy< TObserver > | |
| Crpp::operators::details::merge_with_t< TObservables > | |
| Cmock_observer_strategy< Type > | |
| Crpp::operators::details::multicast_t< Subject > | |
| Crpp::details::never_strategy< Type > | |
| Crpp::schedulers::new_thread | Scheduler which schedules invoking of schedulables to another thread via queueing tasks with priority to time_point and order |
| Crpp::utils::none | |
| Crpp::details::observers::none_disposables_strategy | |
| Crpp::utils::none_mutex | |
| ▼Crpp::observable< Type, Strategy > | Base class for any observable used in RPP. It handles core callbacks of observable |
| Crpp::grouped_observable< KeyType, Type, Strategy > | Extension over rpp::observable for some "subset" of values from original observable grouped by some key. It has get_key() member function. Used in group_by operator to represent grouped observable |
| ▼Crpp::observable< Type, details::observables::blocking_strategy< Type, Strategy > > | |
| Crpp::blocking_observable< Type, Strategy > | Extension over rpp::observable with set of blocking operators - it waits till completion of underlying observable |
| ▼Crpp::observable< Type, details::observables::dynamic_strategy< Type > > | |
| Crpp::dynamic_observable< Type > | Type-erased version of the rpp::observable. Any observable can be converted to dynamic_observable via rpp::observable::as_dynamic member function |
| ▼Crpp::observable< Type, details::variant_observable_strategy< Type, Observables... > > | |
| Crpp::variant_observable< Type, Observables > | Extension over rpp::observable to provide ability statically keep one of multiple observables |
| Crpp::details::observer_impl< Type, Strategy, DisposablesStrategy > | |
| ▼Crpp::details::observer_impl< Type, rpp::details::observers::dynamic_strategy< Type >, details::observers::none_disposables_strategy > | |
| Crpp::observer< Type, rpp::details::observers::dynamic_strategy< Type > > | |
| ▼Crpp::details::observer_impl< Type, Strategy, details::observers::deduce_optimal_disposables_strategy_t< Strategy::preferred_disposables_mode > > | |
| ▼Crpp::observer< Type, details::observers::dynamic_strategy< Type > > | |
| Crpp::dynamic_observer< Type > | Type-erased version of the rpp::observer. Any observer can be converted to dynamic_observer via rpp::observer::as_dynamic member function |
| Crpp::observer< Type, ObserverStrategy > | |
| Crpp::observer< Type, Strategy > | Base class for any observer used in RPP. It handles core callbacks of observers. Objects of this class would be passed to subscribe of observable |
| ▼Crpp::details::observer_impl< Type, Strategy, DisposableStrategy > | |
| Crpp::observer< Type, details::observers::override_disposables_strategy< Strategy, DisposableStrategy > > | |
| Crppgrpc::details::base_writer< TData >::observer_strategy | |
| Crpp::details::observers::observer_vtable< Type > | |
| ▼Crpp::details::observers::observer_vtable< rpp::utils::extract_observer_type_t< TObs > > | |
| Crpp::details::observers::type_erased_observer< TObs > | |
| Crpp::operators::details::timeout_disposable< TObserver, TFallbackObservable, Container >::observer_with_timeout | |
| Crpp::operators::details::on_error_resume_next_inner_observer_strategy< TObserver > | |
| Crpp::operators::details::on_error_resume_next_observer_strategy< TObserver, Selector > | |
| Crpp::operators::details::buffer_t::operator_traits< T > | |
| Crpp::operators::details::combining_operator_t< TDisposable, TStrategy, TSelector, TObservables >::operator_traits< T > | |
| Crpp::operators::details::concat_t::operator_traits< T > | |
| Crpp::operators::details::debounce_t< Scheduler >::operator_traits< T > | |
| Crpp::operators::details::delay_t< Scheduler, ClearOnError >::operator_traits< T > | |
| Crpp::operators::details::distinct_t::operator_traits< T > | |
| Crpp::operators::details::distinct_until_changed_t< EqualityFn >::operator_traits< T > | |
| Crpp::operators::details::element_at_t::operator_traits< T > | |
| Crpp::operators::details::filter_t< Fn >::operator_traits< T > | |
| Crpp::operators::details::finally_t< LastFn >::operator_traits< T > | |
| Crpp::operators::details::first_t::operator_traits< T > | |
| Crpp::operators::details::group_by_t< KeySelector, ValueSelector, KeyComparator >::operator_traits< T > | |
| Crpp::operators::details::last_t::operator_traits< T > | |
| Crpp::operators::details::map_t< Fn >::operator_traits< T > | |
| Crpp::operators::details::merge_t::operator_traits< T > | |
| Crpp::operators::details::merge_with_t< TObservables >::operator_traits< T > | |
| Crpp::operators::details::on_error_resume_next_t< Selector >::operator_traits< T > | |
| Crpp::operators::details::reduce_no_seed_t< Accumulator >::operator_traits< T > | |
| Crpp::operators::details::reduce_t< Seed, Accumulator >::operator_traits< T > | |
| Crpp::operators::details::retry_t::operator_traits< T > | |
| Crpp::operators::details::retry_when_t< TNotifier >::operator_traits< T > | |
| Crpp::operators::details::scan_no_seed_t< Fn >::operator_traits< T > | |
| Crpp::operators::details::scan_t< InitialValue, Fn >::operator_traits< T > | |
| Crpp::operators::details::skip_t::operator_traits< T > | |
| Crpp::operators::details::subscribe_on_t< TScheduler >::operator_traits< T > | |
| Crpp::operators::details::switch_on_next_t::operator_traits< T > | |
| Crpp::operators::details::take_last_t::operator_traits< T > | |
| Crpp::operators::details::take_t::operator_traits< T > | |
| Crpp::operators::details::take_until_t< TObservable >::operator_traits< T > | |
| Crpp::operators::details::take_while_t< Fn >::operator_traits< T > | |
| Crpp::operators::details::tap_t< OnNext, OnError, OnCompleted >::operator_traits< T > | |
| Crpp::operators::details::throttle_t< Scheduler >::operator_traits< T > | |
| Crpp::operators::details::timeout_t< TFallbackObservable, TScheduler >::operator_traits< T > | |
| Crpp::operators::details::timeout_with_error_t< TScheduler >::operator_traits< T > | |
| Crpp::operators::details::window_t::operator_traits< T > | |
| Crpp::operators::details::window_toggle_t< TOpeningsObservable, TClosingsSelectorFn >::operator_traits< T > | |
| Crpp::operators::details::with_latest_from_t< TSelector, TObservables >::operator_traits< T > | |
| Csimple_map< Fn >::operator_traits< T > | |
| Crpp::schedulers::details::optional_mutex< Mutex > | |
| Crpp::details::observers::override_disposables_strategy< S, DisposableStrategy > | |
| Crpp::utils::pack_to_tuple | |
| Crpp::utils::value_with_mutex< T >::pointer_under_lock | |
| Crpp::subjects::details::publish_subject_base< Type, Serialized > | |
| ▼Crpp::subjects::details::publish_subject_base< Type, false > | |
| Crpp::subjects::publish_subject< TData > | |
| Crpp::subjects::publish_subject< T > | |
| Crpp::subjects::publish_subject< Type > | Subject which just multicasts values to observers subscribed on it. It contains two parts: observer and observable at the same time |
| ▼Crpp::subjects::details::publish_subject_base< Type, true > | |
| Crpp::subjects::serialized_publish_subject< TData > | |
| Crpp::subjects::serialized_publish_subject< Type > | Serialized version of rpp::subjects::publish_subject |
| ▼Cstd::range_error | |
| Crpp::utils::out_of_range | |
| Crpp::operators::details::reduce_no_seed_observer_strategy< TObserver, Accumulator > | |
| Crpp::operators::details::reduce_observer_strategy< TObserver, Accumulator > | |
| Crpp::details::ref_count_on_subscribe_t< T > | |
| Crpp::details::ref_count_on_subscribe_t< rpp::connectable_observable< OriginalObservable, Subject > > | |
| Crpp::operators::details::ref_count_t | |
| Crpp::operators::details::repeat_t | |
| Crpp::utils::repeated_container< T > | |
| Crpp::subjects::details::replay_subject_base< Type, Serialized > | |
| ▼Crpp::subjects::details::replay_subject_base< Type, false > | |
| Crpp::subjects::replay_subject< Type > | Same as rpp::subjects::publish_subject but send all earlier emitted values to any new observers |
| ▼Crpp::subjects::details::replay_subject_base< Type, true > | |
| Crpp::subjects::serialized_replay_subject< Type > | Same as rpp::subjects::replay_subject but on_next/on_error/on_completed calls are serialized via mutex |
| Crpp::utils::rethrow_error_t | |
| Crpp::operators::details::retry_observer_strategy< TObserver, TObservable > | |
| Crpp::operators::details::retry_t | |
| Crpp::operators::details::retry_when_impl_inner_strategy< TObserver, TObservable, TNotifier > | |
| Crpp::operators::details::retry_when_impl_strategy< TObserver, TObservable, TNotifier > | |
| Crpp::operators::details::retry_when_t< TNotifier > | |
| Crpp::utils::return_true | |
| Crpp::schedulers::run_loop | Scheduler which schedules execution via queueing tasks, but execution of tasks should be manually dispatched |
| ▼Cstd::runtime_error | |
| Crpp::utils::more_disposables_than_expected | |
| Crpp::utils::not_enough_emissions | |
| Crpp::utils::timeout_reached | |
| Crppgrpc::utils::reactor_failed | |
| Crppqt::utils::no_active_qapplication | |
| Crpp::operators::details::scan_no_seed_observer_strategy< TObserver, Fn > | |
| Crpp::operators::details::scan_observer_strategy< TObserver, Seed, Fn > | |
| ▼Crpp::schedulers::details::schedulable_base | |
| Crpp::schedulers::details::specific_schedulable< NowStrategy, Fn, Handler, Args > | |
| Crpp::schedulers::details::schedulables_queue< NowStrategy > | |
| Crpp::schedulers::details::schedulables_queue< rpp::schedulers::current_thread::worker_strategy > | |
| Crpp::schedulers::details::schedulables_queue< rpp::schedulers::test_scheduler::worker_strategy > | |
| Crpp::schedulers::details::schedulables_queue< worker_strategy > | |
| ▼Cgrpc::ServerBidiReactor | |
| Crppgrpc::server_bidi_reactor< Request, Response > | RPP's based implementation for grpc server bidirectional reactor |
| ▼Cgrpc::ServerReadReactor | |
| Crppgrpc::server_read_reactor< Request > | RPP's based implementation for grpc server read reactor |
| ▼Cgrpc::ServerWriteReactor | |
| Crppgrpc::server_write_reactor< Response > | RPP's based implementation for grpc server write reactor |
| Crpp::details::shared_container< Container > | |
| Crpp::schedulers::details::shared_queue_data | |
| Csimple_map< Fn > | |
| Crpp::operators::details::skip_observer_strategy< TObserver > | |
| Crpp::operators::details::start_with_t< TObservables > | |
| Crpp::operators::details::start_with_values_t< PackedContainer, TScheduler > | |
| Crpp::schedulers::test_scheduler::state | |
| Crpp::details::ref_count_on_subscribe_t< rpp::connectable_observable< OriginalObservable, Subject > >::state_t | |
| Crpp::operators::details::window_toggle_state< TObserver, TClosingsSelectorFn >::state_t | |
| Crpp::details::disposables::static_disposables_container< Count > | Container with fixed std::array as underlying storage |
| Crpp::details::disposables::static_disposables_container< 0 > | |
| Crpp::utils::static_mem_fn< Fn, Inverse > | |
| Crppasio::schedulers::strand | Asio based scheduler where each worker is assigned an asio strand to execute schedulables with the guarantee that none of those schedulables will execute concurrently |
| Crpp::subjects::details::subject_on_subscribe_strategy< Type, OnSubscribe, DisposableStrategy > | |
| Crpp::operators::details::subscribe_on_schedulable< TObservableChainStrategy > | |
| Crpp::operators::details::subscribe_on_t< TScheduler > | |
| Crpp::operators::details::subscribe_t< Args > | |
| Crpp::operators::details::subscribe_t< observer< Type, ObserverStrategy > > | |
| Crpp::operators::details::subscribe_t< ObserverStrategy > | |
| Crpp::operators::details::subscribe_t< OnNext, OnError, OnCompleted > | |
| Crpp::operators::details::subscribe_t< rpp::composite_disposable_wrapper, observer< Type, ObserverStrategy > > | |
| Crpp::operators::details::subscribe_t< rpp::composite_disposable_wrapper, ObserverStrategy > | |
| Crpp::operators::details::subscribe_t< rpp::composite_disposable_wrapper, OnNext, OnError, OnCompleted > | |
| Crpp::operators::details::switch_on_next_inner_observer_strategy< TObserver > | |
| Crpp::operators::details::switch_on_next_observer_strategy< TObserver > | |
| Crpp::operators::details::take_last_observer_strategy< TObserver > | |
| Crpp::operators::details::take_observer_strategy< TObserver > | |
| ▼Crpp::operators::details::take_until_observer_strategy_base< TObserver > | |
| Crpp::operators::details::take_until_observer_strategy< TObserver > | |
| Crpp::operators::details::take_until_throttle_observer_strategy< TObserver > | |
| Crpp::operators::details::take_until_t< TObservable > | |
| Crpp::operators::details::take_while_observer_strategy< TObserver, Fn > | |
| Crpp::operators::details::tap_observer_strategy< TObserver, OnNext, OnError, OnCompleted > | |
| Crpp::operators::details::template_multicast_t< Subject > | |
| Crpp::schedulers::test_scheduler | |
| Crpp::schedulers::thread_pool | Scheduler owning static thread pool of workers and using "some" thread from this pool on create_worker call |
| Crpp::operators::details::throttle_observer_strategy< TObserver, Scheduler > | |
| Crpp::operators::details::timeout_disposable_wrapper< TObserver, TFallbackObservable, Container > | |
| Crpp::operators::details::timeout_observer_strategy< TObserver, TFallbackObservable, Container, TScheduler > | |
| Crpp::operators::details::timeout_t< TFallbackObservable, TScheduler > | |
| Crpp::operators::details::timeout_with_error_t< TScheduler > | |
| Crpp::utils::details::traits< Base > | |
| ▼Cstd::true_type | |
| Crpp::schedulers::constraint::details::is_worker< rpp::schedulers::worker< Strategy > > | |
| Crpp::utils::is_not_template_callable_t< R(*)(Args...)> | |
| Crpp::utils::is_not_template_callable_t< R(T::*)(Args...) const > | |
| Crpp::utils::is_not_template_callable_t< R(T::*)(Args...)> | |
| Crpp::utils::is_not_template_callable_t< T, std::void_t< decltype(&T::operator())> > | |
| ▼CTs... | |
| Crpp::utils::overloaded< Ts > | |
| Crpp::details::tuple_impl< typename,... > | |
| ▼Crpp::details::tuple_impl< std::index_sequence_for< Args... >, Args... > | |
| Crpp::utils::tuple< TArgs... > | |
| Crpp::utils::tuple< TObservables... > | |
| Crpp::utils::tuple< std::optional< Args >... > | |
| Crpp::utils::tuple< rpp::utils::value_with_mutex< std::optional< RestArgs > >... > | |
| Crpp::utils::tuple< std::deque< Args >... > | |
| Crpp::utils::tuple< Handler, Args... > | |
| Crpp::utils::tuple< Args > | |
| Crpp::details::tuple_leaf< size_t, T > | |
| ▼Crpp::details::tuple_leaf< Indices, Args > | |
| Crpp::details::tuple_impl< std::index_sequence< Indices... >, Args... > | |
| ▼Cstd::type_identity | |
| ▼Crpp::utils::details::unique_variant_t< std::variant< Ts... >, Us... > | |
| Crpp::utils::details::unique_variant_t< std::variant< Ts... >, U, Us... > | |
| ▼Crpp::utils::details::unique_variant_t< std::variant< Ts..., U >, Us... > | |
| Crpp::utils::details::unique_variant_t< std::variant< Ts... >, U, Us... > | |
| Crpp::utils::details::unique_variant_t< T, Ts > | |
| Crpp::utils::types< Args > | |
| Crpp::memory_model::use_shared | |
| Crpp::memory_model::use_stack | |
| Crpp::utils::value_with_mutex< T > | |
| Crpp::utils::value_with_mutex< Observer > | |
| Crpp::utils::value_with_mutex< rpp::disposable_wrapper_impl > | |
| Crpp::utils::value_with_mutex< rpp::operators::details::timeout_disposable::observer_with_timeout > | |
| Crpp::utils::value_with_mutex< rpp::operators::details::window_toggle_state::state_t > | |
| Crpp::utils::value_with_mutex< std::queue< TObservable > > | |
| Crpp::utils::value_with_mutex< TObserver > | |
| Crpp::utils::value_with_mutex< Type > | |
| Crpp::subjects::details::replay_subject_base< Type, Serialized >::replay_state::value_with_time | |
| Crpp::details::variant_observable_strategy< Type, Observables > | |
| Crpp::details::observers::observer_vtable< Type >::vtable_t | |
| Crpp::operators::details::window_observer_strategy< TObserver > | |
| Crpp::operators::details::window_toggle_closing_observer_strategy< TState > | |
| Crpp::operators::details::window_toggle_observer_strategy< TObserver, TOpeningsObservable, TClosingsSelectorFn > | |
| Crpp::operators::details::window_toggle_opening_observer_strategy< TState > | |
| Crpp::operators::details::window_toggle_state< TObserver, TClosingsSelectorFn > | |
| Crpp::operators::details::with_latest_from_inner_observer_strategy< I, Observer, TSelector, RestArgs > | |
| Crpp::operators::details::with_latest_from_observer_strategy< Observer, TSelector, OriginalValue, RestArgs > | |
| Crpp::operators::details::with_latest_from_t< TSelector, TObservables > | |
| Crpp::schedulers::worker< Strategy > | |
| Crpp::schedulers::current_thread::worker_strategy | |
| Crpp::schedulers::immediate::worker_strategy | |
| Crpp::schedulers::new_thread::worker_strategy | |
| Crpp::schedulers::test_scheduler::worker_strategy | |
1.12.0