MCPcopy Create free account

hub / github.com/AlexInLog/ReactivePlusPlus / types & classes

Types & classes437 in github.com/AlexInLog/ReactivePlusPlus

↓ 2 callersClasssimple_map
src/examples/rpp/doxygen/readme.cpp:13
↓ 1 callersClassdelay_to
* @brief Provide timepoint of next execution explicitly */
src/rpp/rpp/schedulers/fwd.hpp:69
EnumConcatStage
src/rpp/rpp/operators/concat.hpp:29
EnumMode
src/rpp/rpp/disposables/interface_disposable.hpp:42
ClassQObject
src/extensions/rppqt/rppqt/sources/fwd.hpp:15
ClassRPP_EMPTY_BASES
src/rpp/rpp/utils/tuple.hpp:49
ClassRppConan
conanfile.py:3
ClassService
src/examples/rppgrpc/communication/server.cpp:10
EnumState
src/rpp/rpp/disposables/composite_disposable.hpp:157
Classadvanced_call
src/rpp/rpp/schedulers/details/queue.hpp:44
Classas_blocking_t
src/rpp/rpp/operators/as_blocking.hpp:20
Classauto_dispose_wrapper
src/rpp/rpp/disposables/fwd.hpp:18
Classauto_dispose_wrapper
src/rpp/rpp/disposables/disposable_wrapper.hpp:28
Classbase_disposable_impl
src/rpp/rpp/disposables/details/base_disposable.hpp:22
Classbase_reader
src/extensions/rppgrpc/rppgrpc/details/base.hpp:111
Classbase_writer
src/extensions/rppgrpc/rppgrpc/details/base.hpp:27
Classbehavior_state
src/rpp/rpp/subjects/behavior_subject.hpp:27
Classbehavior_subject
src/rpp/rpp/subjects/fwd.hpp:36
Classbehavior_subject
src/rpp/rpp/subjects/behavior_subject.hpp:124
Classbehavior_subject_base
src/rpp/rpp/subjects/behavior_subject.hpp:25
Classblocking_disposable
src/rpp/rpp/observables/blocking_observable.hpp:22
Classblocking_observable
src/rpp/rpp/observables/fwd.hpp:179
Classblocking_observable
src/rpp/rpp/observables/blocking_observable.hpp:91
Classblocking_strategy
src/rpp/rpp/observables/fwd.hpp:52
Classblocking_strategy
src/rpp/rpp/observables/blocking_observable.hpp:47
Classboolean_disposables_strategy
* @brief Just control is_disposed or not via boolean and ignore upstreams at all */
src/rpp/rpp/observers/details/fwd.hpp:55
Classboolean_disposables_strategy
src/rpp/rpp/observers/details/disposables_strategy.hpp:59
Classbuffer_observer_strategy
src/rpp/rpp/operators/buffer.hpp:23
Classbuffer_t
src/rpp/rpp/operators/buffer.hpp:70
Classcallback_disposable
src/rpp/rpp/disposables/fwd.hpp:75
Classcallback_disposable
src/rpp/rpp/disposables/callback_disposable.hpp:26
Classchain
src/rpp/rpp/observables/fwd.hpp:67
Classchain
src/rpp/rpp/observables/details/chain_strategy.hpp:21
Classchain<TStrategy>
src/rpp/rpp/observables/details/chain_strategy.hpp:76
Classclient_bidi_reactor
src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:36
Classclient_bidi_reactor
src/extensions/rppgrpc/rppgrpc/fwd.hpp:38
Classclient_read_reactor
src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:175
Classclient_read_reactor
src/extensions/rppgrpc/rppgrpc/fwd.hpp:44
Classclient_write_reactor
src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:111
Classclient_write_reactor
src/extensions/rppgrpc/rppgrpc/fwd.hpp:41
Classcombine_latest_disposable
src/rpp/rpp/operators/combine_latest.hpp:22
Classcombine_latest_observer_strategy
src/rpp/rpp/operators/combine_latest.hpp:42
Classcombine_latest_t
src/rpp/rpp/operators/combine_latest.hpp:67
Classcombining_disposable
src/rpp/rpp/operators/details/combining_strategy.hpp:26
Classcombining_observer_strategy
src/rpp/rpp/operators/details/combining_strategy.hpp:50
Classcombining_operator_t
src/rpp/rpp/operators/details/combining_strategy.hpp:80
Classcompleted
src/rpp/rpp/subjects/details/subject_state.hpp:30
Classcomposite_disposable
src/rpp/rpp/disposables/fwd.hpp:72
Classcomposite_disposable
* @brief Disposable which can keep some other sub-disposables. When this root disposable is disposed, then all sub-disposables would be disposed too.
src/rpp/rpp/disposables/composite_disposable.hpp:174
Classcomposite_disposable_impl
src/rpp/rpp/disposables/composite_disposable.hpp:30
Classcomputational
src/rpp/rpp/schedulers/fwd.hpp:164
Classcomputational
* @brief Scheduler owning static thread pool of workers and using "some" thread from this pool on `create_worker` call * @warning Actually it is
src/rpp/rpp/schedulers/computational.hpp:29
Classconcat_disposable
src/rpp/rpp/operators/concat.hpp:38
Classconcat_inner_observer_strategy
src/rpp/rpp/operators/concat.hpp:27
Classconcat_observer_strategy
src/rpp/rpp/operators/concat.hpp:152
Classconcat_source_observer_strategy
src/rpp/rpp/sources/concat.hpp:51
Classconcat_state_t
src/rpp/rpp/sources/concat.hpp:25
Classconcat_strategy
src/rpp/rpp/sources/concat.hpp:112
Classconcat_t
src/rpp/rpp/operators/concat.hpp:199
Classconnectable_observable
src/rpp/rpp/observables/fwd.hpp:86
Classconnectable_observable
src/rpp/rpp/observables/connectable_observable.hpp:72
Classconvertible_to_any
src/rpp/rpp/utils/utils.hpp:67
Classcoordinates
src/examples/rpp/sfml/snake/utils.hpp:14
Classcopy_count_tracker
src/tests/utils/copy_count_tracker.hpp:20
Classcreate_strategy
src/rpp/rpp/sources/create.hpp:19
Classcurrent_thread
src/rpp/rpp/schedulers/fwd.hpp:160
Classcurrent_thread
* @brief Schedules execution of schedulables via queueing tasks to the caller thread with priority to time_point and order. * @warning Caller thr
src/rpp/rpp/schedulers/current_thread.hpp:85
Classcurrent_thread_queue_guard
src/extensions/rppasio/rppasio/schedulers/strand.hpp:36
Classcustom_disposable
src/tests/rpp/test_disposables.cpp:18
Classdebounce_disposable
src/rpp/rpp/operators/debounce.hpp:22
Classdebounce_disposable_wrapper
src/rpp/rpp/operators/debounce.hpp:25
Classdebounce_observer_strategy
src/rpp/rpp/operators/debounce.hpp:112
Classdebounce_t
src/rpp/rpp/operators/debounce.hpp:149
Classdefer_strategy
src/rpp/rpp/sources/defer.hpp:20
Classdelay_disposable
src/rpp/rpp/operators/delay.hpp:39
Classdelay_disposable_wrapper
src/rpp/rpp/operators/delay.hpp:60
Classdelay_from_now
* @brief Timepoint of next execution would be calculcated from NOW timpoint (time of returning from schedulable) * * @details Implementation
src/rpp/rpp/schedulers/fwd.hpp:35
Classdelay_from_this_timepoint
* @brief Timepoint of next execution would be calculcated from timepoint of current scheduling * * @details Implementation looks like this
src/rpp/rpp/schedulers/fwd.hpp:56
Classdelay_observer_strategy
src/rpp/rpp/operators/delay.hpp:70
Classdelay_t
src/rpp/rpp/operators/delay.hpp:169
Classdisposable_with_observer
src/rpp/rpp/subjects/details/subject_state.hpp:43
Classdisposable_wrapper_base
src/rpp/rpp/disposables/disposable_wrapper.hpp:54
Classdisposable_wrapper_impl
src/rpp/rpp/disposables/fwd.hpp:27
Classdisposable_wrapper_impl
src/rpp/rpp/disposables/disposable_wrapper.hpp:141
Enumdisposables_mode
src/rpp/rpp/observers/details/fwd.hpp:21
Classdisposed
src/rpp/rpp/subjects/details/subject_state.hpp:34
Classdistinct_observer_strategy
src/rpp/rpp/operators/distinct.hpp:24
Classdistinct_t
src/rpp/rpp/operators/distinct.hpp:50
Classdistinct_until_changed_observer_strategy
src/rpp/rpp/operators/distinct_until_changed.hpp:23
Classdistinct_until_changed_t
src/rpp/rpp/operators/distinct_until_changed.hpp:51
Classdynamic_connectable_observable
src/rpp/rpp/observables/fwd.hpp:176
Classdynamic_connectable_observable
src/rpp/rpp/observables/dynamic_connectable_observable.hpp:18
Classdynamic_disposables_container
* @brief Container with std::vector as underlying storage. */
src/rpp/rpp/disposables/fwd.hpp:59
Classdynamic_disposables_container
src/rpp/rpp/disposables/details/container.hpp:21
Classdynamic_disposables_strategy
src/rpp/rpp/observables/details/disposables_strategy.hpp:18
Classdynamic_observable
src/rpp/rpp/observables/fwd.hpp:173
Classdynamic_observable
src/rpp/rpp/observables/dynamic_observable.hpp:88
Classdynamic_observer
src/rpp/rpp/observers/fwd.hpp:106
Classdynamic_observer
src/rpp/rpp/observers/dynamic_observer.hpp:126
Classdynamic_strategy
src/rpp/rpp/observables/fwd.hpp:49
next →1–100 of 437, ranked by callers