ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
Class List
Here are the classes, structs, unions and interfaces with brief descriptions:
[detail level 12345]
 Nrpp
 Ndetails
 Ndisposables
 Cdynamic_disposables_container
 Cstatic_disposables_containerContainer with fixed std::array as underlying storage
 Cstatic_disposables_container< 0 >
 Nobservables
 Cblocking_disposable
 Cblocking_strategy
 Cchain
 Cchain< TStrategy >
 Cdynamic_disposables_strategy
 Cdynamic_strategy
 Cfake_strategy
 Cfixed_disposables_strategy
 Cmake_chain
 Cmake_chain< New, chain< Args... > >
 Nobservers
 Cdynamic_strategy
 Cfake_strategy
 Clambda_strategy
 Clocal_disposables_strategy
 Cnone_disposables_strategy
 Cobserver_vtable
 Cvtable_t
 Coverride_disposables_strategy
 Ctype_erased_observer
 Cauto_dispose_wrapper
 Cbase_disposable_impl
 Cconcat_source_observer_strategy
 Cconcat_state_t
 Cconcat_strategy
 Ccreate_strategy
 Cdefer_strategy
 Cdisposable_wrapper_base
 Cempty_strategy
 Cenable_wrapper_from_this
 Cerror_strategy
 Cfrom_callable_invoke
 Cfrom_iterable_schedulable
 Cfrom_iterable_strategy
 Cinterval_schedulable
 Cinterval_strategy
 Cnever_strategy
 Cobserver_impl
 Cref_count_on_subscribe_t
 Cref_count_on_subscribe_t< rpp::connectable_observable< OriginalObservable, Subject > >
 Cstate_t
 Crefocunt_disposable_inner
 Cshared_container
 Ctuple_impl
 Ctuple_impl< std::index_sequence< Indices... >, Args... >
 Ctuple_leaf
 Cvariant_observable_strategy
 Nmemory_model
 Cuse_shared
 Cuse_stack
 Noperators
 Ndetails
 Cas_blocking_t
 Cbuffer_observer_strategy
 Cbuffer_t
 Coperator_traits
 Ccombine_latest_disposable
 Ccombine_latest_observer_strategy
 Ccombine_latest_t
 Ccombining_disposable
 Ccombining_observer_strategy
 Ccombining_operator_t
 Coperator_traits
 Cconcat_disposable
 Cconcat_inner_observer_strategy
 Cconcat_observer_strategy
 Cconcat_t
 Coperator_traits
 Cdebounce_disposable
 Cdebounce_disposable_wrapper
 Cdebounce_observer_strategy
 Cdebounce_t
 Coperator_traits
 Cdelay_disposable
 Cdelay_disposable_wrapper
 Cdelay_observer_strategy
 Cdelay_t
 Coperator_traits
 Cdistinct_observer_strategy
 Cdistinct_t
 Coperator_traits
 Cdistinct_until_changed_observer_strategy
 Cdistinct_until_changed_t
 Coperator_traits
 Celement_at_observer_strategy
 Celement_at_t
 Coperator_traits
 Cemission
 Cfilter_observer_strategy
 Cfilter_t
 Coperator_traits
 Cfinally_t
 Coperator_traits
 Cfirst_observer_strategy
 Cfirst_t
 Coperator_traits
 Cflat_map_t
 Cforwarding_subject
 Cgroup_by_inner_observer_strategy
 Cgroup_by_observable_strategy
 Cgroup_by_observer_strategy
 Cgroup_by_t
 Coperator_traits
 Cinfinite_repeat_t
 Clast_observer_strategy
 Clast_t
 Coperator_traits
 Clift_operator
 Cmap_observer_strategy
 Cmap_t
 Coperator_traits
 Cmerge_disposable
 Cmerge_observer_base_strategy
 Cmerge_observer_inner_strategy
 Cmerge_observer_strategy
 Cmerge_t
 Coperator_traits
 Cmerge_with_t
 Coperator_traits
 Cmulticast_t
 Con_error_resume_next_disposable
 Con_error_resume_next_inner_observer_strategy
 Con_error_resume_next_observer_strategy
 Con_error_resume_next_t
 Coperator_traits
 Creduce_no_seed_observer_strategy
 Creduce_no_seed_t
 Coperator_traits
 Creduce_observer_strategy
 Creduce_t
 Coperator_traits
 Cref_count_t
 Crepeat_t
 Cretry_observer_strategy
 Cretry_state_t
 Cretry_t
 Coperator_traits
 Cretry_when_impl_inner_strategy
 Cretry_when_impl_strategy
 Cretry_when_state
 Cretry_when_t
 Coperator_traits
 Cscan_no_seed_observer_strategy
 Cscan_no_seed_t
 Coperator_traits
 Cscan_observer_strategy
 Cscan_t
 Coperator_traits
 Cskip_observer_strategy
 Cskip_t
 Coperator_traits
 Cstart_with_t
 Cstart_with_values_t
 Csubscribe_on_schedulable
 Csubscribe_on_t
 Coperator_traits
 Csubscribe_t
 Csubscribe_t< observer< Type, ObserverStrategy > >
 Csubscribe_t< ObserverStrategy >
 Csubscribe_t< OnNext, OnError, OnCompleted >
 Csubscribe_t< rpp::composite_disposable_wrapper, observer< Type, ObserverStrategy > >
 Csubscribe_t< rpp::composite_disposable_wrapper, ObserverStrategy >
 Csubscribe_t< rpp::composite_disposable_wrapper, OnNext, OnError, OnCompleted >
 Cswitch_on_next_inner_observer_strategy
 Cswitch_on_next_observer_strategy
 Cswitch_on_next_state_t
 Cswitch_on_next_t
 Coperator_traits
 Ctake_last_observer_strategy
 Ctake_last_t
 Coperator_traits
 Ctake_observer_strategy
 Ctake_t
 Coperator_traits
 Ctake_until_disposable
 Ctake_until_observer_strategy
 Ctake_until_observer_strategy_base
 Ctake_until_t
 Coperator_traits
 Ctake_until_throttle_observer_strategy
 Ctake_while_observer_strategy
 Ctake_while_t
 Coperator_traits
 Ctap_observer_strategy
 Ctap_t
 Coperator_traits
 Ctemplate_multicast_t
 Cthrottle_observer_strategy
 Cthrottle_t
 Coperator_traits
 Ctimeout_disposable
 Cobserver_with_timeout
 Ctimeout_disposable_wrapper
 Ctimeout_observer_strategy
 Ctimeout_t
 Coperator_traits
 Ctimeout_with_error_t
 Coperator_traits
 Cwindow_observer_strategy
 Cwindow_t
 Coperator_traits
 Cwindow_toggle_closing_observer_strategy
 Cwindow_toggle_observer_strategy
 Cwindow_toggle_opening_observer_strategy
 Cwindow_toggle_state
 Cstate_t
 Cwindow_toggle_t
 Coperator_traits
 Cwith_latest_from_disposable
 Cwith_latest_from_inner_observer_strategy
 Cwith_latest_from_observer_strategy
 Cwith_latest_from_t
 Coperator_traits
 Czip_disposable
 Czip_observer_strategy
 Czip_t
 Nschedulers
 Nconstraint
 Ndetails
 Cis_worker
 Cis_worker< rpp::schedulers::worker< Strategy > >
 Ndetails
 Cfake_schedulable_handler
 Coptional_mutex
 Cschedulable_base
 Cadvanced_call
 Cschedulables_queue
 Cshared_queue_data
 Cspecific_schedulable
 CcomputationalScheduler owning static thread pool of workers and using "some" thread from this pool on create_worker call
 Ccurrent_threadSchedules execution of schedulables via queueing tasks to the caller thread with priority to time_point and order
 Cis_queue_is_empty
 Cworker_strategy
 Cdelay_from_nowTimepoint of next execution would be calculcated from NOW timpoint (time of returning from schedulable)
 Cdelay_from_this_timepointTimepoint of next execution would be calculcated from timepoint of current scheduling
 Cdelay_toProvide timepoint of next execution explicitly
 CimmediateImmediately calls provided schedulable or waits for time_point (in the caller-thread)
 Cworker_strategy
 Cnew_threadScheduler which schedules invoking of schedulables to another thread via queueing tasks with priority to time_point and order
 Cworker_strategy
 Crun_loopScheduler which schedules execution via queueing tasks, but execution of tasks should be manually dispatched
 Ctest_scheduler
 Cstate
 Cworker_strategy
 Cthread_poolScheduler owning static thread pool of workers and using "some" thread from this pool on create_worker call
 Cworker
 Nsubjects
 Ndetails
 Cbehavior_subject_base
 Ccompleted
 Cdisposed
 Cpublish_subject_base
 Creplay_subject_base
 Csubject_on_subscribe_strategy
 Csubject_state
 Cbehavior_subjectSame as rpp::subjects::publish_subject but keeps last value (or default) and emits it to newly subscribed observer
 Cpublish_subjectSubject which just multicasts values to observers subscribed on it. It contains two parts: observer and observable at the same time
 Creplay_subjectSame as rpp::subjects::publish_subject but send all earlier emitted values to any new observers
 Cserialized_behavior_subjectSame as rpp::subjects::behavior_subject but on_next/on_error/on_completed calls are serialized via mutex
 Cserialized_publish_subjectSerialized version of rpp::subjects::publish_subject
 Cserialized_replay_subjectSame as rpp::subjects::replay_subject but on_next/on_error/on_completed calls are serialized via mutex
 Nutils
 Ndetails
 Ctraits
 Cunique_variant_t
 Cunique_variant_t< std::variant< Ts... >, U, Us... >
 Cconvertible_to_any
 Cempty_function_any_by_lvalue_t
 Cempty_function_any_t
 Cempty_function_t
 Cequal_to
 Cfinally_actionCalls passed function during destruction
 Cfunction_traits
 Cfunction_traits< R(*)()>
 Cfunction_traits< R(*)(Args...)>
 Cfunction_traits< R(T::*)(Args...) const >
 Cfunction_traits< R(T::*)(Args...)>
 Cinfinite_repeated_container
 Citerator
 Cis_not_template_callable_t
 Cis_not_template_callable_t< R(*)(Args...)>
 Cis_not_template_callable_t< R(T::*)(Args...) const >
 Cis_not_template_callable_t< R(T::*)(Args...)>
 Cis_not_template_callable_t< T, std::void_t< decltype(&T::operator())> >
 Cless
 Cmore_disposables_than_expected
 Cnone
 Cnone_mutex
 Cnot_enough_emissions
 Cout_of_range
 Coverloaded
 Cpack_to_tuple
 Crepeated_container
 Citerator
 Crethrow_error_t
 Creturn_true
 Cstatic_mem_fn
 Ctimeout_reached
 Ctuple
 Ctypes
 Cvalue_with_mutex
 Cpointer_under_lock
 Cblocking_observableExtension over rpp::observable with set of blocking operators - it waits till completion of underlying observable
 Ccallback_disposableDisposable invokes underlying callable on disposing
 Ccomposite_disposableDisposable which can keep some other sub-disposables. When this root disposable is disposed, then all sub-disposables would be disposed too
 Ccomposite_disposable_implDisposable which can keep some other sub-disposables. When this root disposable is disposed, then all sub-disposables would be disposed too
 Cconnectable_observableExtension over raw observable with ability to be manually connected at any time or ref_counting (sharing same observable between multiple observers)
 Cdisposable_wrapper_implMain RPP wrapper over disposables
 Cdynamic_observableType-erased version of the rpp::observable. Any observable can be converted to dynamic_observable via rpp::observable::as_dynamic member function
 Cdynamic_observerType-erased version of the rpp::observer. Any observer can be converted to dynamic_observer via rpp::observer::as_dynamic member function
 Cgrouped_observableExtension 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
 Cinterface_composite_disposable
 Cinterface_disposableInterface of disposable
 CobservableBase class for any observable used in RPP. It handles core callbacks of observable
 CobserverBase class for any observer used in RPP. It handles core callbacks of observers. Objects of this class would be passed to subscribe of observable
 Cobserver< Type, details::observers::override_disposables_strategy< Strategy, DisposableStrategy > >
 Cobserver< Type, rpp::details::observers::dynamic_strategy< Type > >
 Crefcount_disposable
 Cvariant_observableExtension over rpp::observable to provide ability statically keep one of multiple observables
 Nrppasio
 Nschedulers
 CstrandAsio based scheduler where each worker is assigned an asio strand to execute schedulables with the guarantee that none of those schedulables will execute concurrently
 Nrppgrpc
 Ndetails
 Cbase_reader
 Cbase_writer
 Cobserver_strategy
 Nutils
 Creactor_failed
 Cclient_bidi_reactorRPP's based implementation for grpc client bidirectional reactor
 Cclient_read_reactorRPP's based implementation for grpc client read reactor
 Cclient_write_reactorRPP's based implementation for grpc client write reactor
 Cserver_bidi_reactorRPP's based implementation for grpc server bidirectional reactor
 Cserver_read_reactorRPP's based implementation for grpc server read reactor
 Cserver_write_reactorRPP's based implementation for grpc server write reactor
 Nrppqt
 Ndetails
 Cfrom_signal_on_event
 Cfrom_signal_on_event< Arg >
 Cfrom_signal_on_event<>
 Nschedulers
 Cmain_thread_schedulerSchedule provided schedulables to main GUI QT thread (where QApplication placed)
 Nutils
 Cno_active_qapplication
 Cmock_observer_strategy
 Cserver
 Csimple_map
 Coperator_traits