Functions — github.com/AlexInLog/ReactivePlusPlus

CodeHub MCPcopy Create free account

hub / github.com/AlexInLog/ReactivePlusPlus / functions

Functions973 in github.com/AlexInLog/ReactivePlusPlus

⨍ Functions 973◇ Types & classes 437

Methodclient_bidi_reactor

src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:43

Methodclient_read_reactor

src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:181

Methodclient_write_reactor

src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:118

Methodcombine_latest_disposable

src/rpp/rpp/operators/combine_latest.hpp:25

Methodcombining_disposable

src/rpp/rpp/operators/details/combining_strategy.hpp:29

Methodcomposite_disposable_impl

src/rpp/rpp/disposables/composite_disposable.hpp:33

Methodcomposite_dispose_impl

src/rpp/rpp/disposables/refcount_disposable.hpp:48

Methodcomposite_dispose_impl

src/rpp/rpp/disposables/refcount_disposable.hpp:76

Methodcomposite_dispose_impl

src/rpp/rpp/disposables/composite_disposable.hpp:154

Methodcomposite_dispose_impl

src/rpp/rpp/subjects/details/subject_state.hpp:153

Methodconcat_disposable

src/rpp/rpp/operators/concat.hpp:42

Methodconcat_observer_strategy

src/rpp/rpp/operators/concat.hpp:158

Methodconcat_state_t

src/rpp/rpp/sources/concat.hpp:27

Methodconcat_strategy

src/rpp/rpp/sources/concat.hpp:116

Methodconfigure

conanfile.py:26

Methodconnectable_observable

src/rpp/rpp/observables/connectable_observable.hpp:79

Methodconvertible_to_any

src/rpp/rpp/utils/utils.hpp:69

Methodcopy_count_tracker

src/tests/utils/copy_count_tracker.hpp:23

src/rpp/rpp/sources/create.hpp:60

src/rpp/rpp/observables/dynamic_observable.hpp:64

Functioncreate_subject_on_subscribe_observable

src/rpp/rpp/subjects/details/subject_on_subscribe.hpp:28

Methodcreate_worker

src/rpp/rpp/schedulers/immediate.hpp:79

Methodcreate_worker

src/rpp/rpp/schedulers/test_scheduler.hpp:92

Methodcreate_worker

src/rpp/rpp/schedulers/computational.hpp:32

Methodcreate_worker

src/rpp/rpp/schedulers/new_thread.hpp:145

Methodcreate_worker

src/rpp/rpp/schedulers/thread_pool.hpp:66

Methodcreate_worker

src/rpp/rpp/schedulers/current_thread.hpp:217

Methodcreate_worker

src/extensions/rppqt/rppqt/schedulers/main_thread.hpp:80

Methodcurrent_thread_queue_guard

src/extensions/rppasio/rppasio/schedulers/strand.hpp:82

Methodcustom_disposable

src/tests/rpp/test_disposables.cpp:20

Methoddata_thread

src/rpp/rpp/schedulers/new_thread.hpp:65

Methoddebounce_disposable

src/rpp/rpp/operators/debounce.hpp:41

Methoddeduce_observer

src/rpp/rpp/operators/group_by.hpp:119

Functiondeduce_optimal_disposables_strategy

src/rpp/rpp/observers/details/fwd.hpp:73

Methoddeduce_timepoint

src/rpp/rpp/subjects/replay_subject.hpp:66

Methoddefer_for

src/rpp/rpp/schedulers/test_scheduler.hpp:75

Methoddefer_for

src/rpp/rpp/schedulers/thread_pool.hpp:43

Methoddefer_for

src/rpp/rpp/schedulers/current_thread.hpp:148

Methoddefer_for

src/tests/rpp/test_delay.cpp:35

Methoddefer_for

src/extensions/rppasio/rppasio/schedulers/strand.hpp:157

Methoddefer_for

src/extensions/rppqt/rppqt/schedulers/main_thread.hpp:38

src/rpp/rpp/schedulers/run_loop.hpp:117

src/rpp/rpp/schedulers/new_thread.hpp:134

src/rpp/rpp/schedulers/thread_pool.hpp:49

src/rpp/rpp/schedulers/current_thread.hpp:170

src/extensions/rppasio/rppasio/schedulers/strand.hpp:166

Methoddelay_disposable

src/rpp/rpp/operators/delay.hpp:43

Methoddelay_from_now

src/rpp/rpp/schedulers/fwd.hpp:37

Methoddelay_from_this_timepoint

src/rpp/rpp/schedulers/fwd.hpp:58

src/rpp/rpp/schedulers/fwd.hpp:71

Methoddispatch_impl

src/rpp/rpp/schedulers/run_loop.hpp:156

Methoddisposable_with_observer

src/rpp/rpp/subjects/details/subject_state.hpp:47

Methoddisposable_wrapper_base

src/rpp/rpp/disposables/disposable_wrapper.hpp:76

src/rpp/rpp/disposables/details/container.hpp:47

src/rpp/rpp/disposables/details/container.hpp:166

src/rpp/rpp/observers/details/disposables_strategy.hpp:39

src/rpp/rpp/observers/details/disposables_strategy.hpp:66

Methoddispose_impl

src/rpp/rpp/disposables/composite_disposable.hpp:43

Methoddispose_impl

src/tests/rpp/test_disposables.cpp:24

src/rpp/rpp/operators/details/repeating_strategy.hpp:102

Methoddrain_queue

src/rpp/rpp/operators/delay.hpp:139

Methoddrain_queue

src/rpp/rpp/schedulers/current_thread.hpp:105

Methoddynamic_connectable_observable

src/rpp/rpp/observables/dynamic_connectable_observable.hpp:29

Methoddynamic_disposables_container

src/rpp/rpp/disposables/details/container.hpp:24

Methoddynamic_observable

src/rpp/rpp/observables/dynamic_observable.hpp:95

Methoddynamic_observer

src/rpp/rpp/observers/dynamic_observer.hpp:133

Methoddynamic_strategy

src/rpp/rpp/observables/dynamic_observable.hpp:38

Methoddynamic_strategy

src/rpp/rpp/observers/dynamic_observer.hpp:96

src/rpp/rpp/operators/delay.hpp:28

Methodemplace_impl

src/rpp/rpp/schedulers/details/queue.hpp:250

Methodemplace_safe

src/rpp/rpp/operators/delay.hpp:117

Functionempty_function

src/rpp/rpp/utils/functors.hpp:33

Methodenable_wrapper_from_this

src/rpp/rpp/disposables/disposable_wrapper.hpp:258

src/rpp/rpp/utils/utils.hpp:196

src/rpp/rpp/utils/utils.hpp:245

src/tests/rpp/test_from.cpp:53

src/tests/rpp/test_concat.cpp:66

src/rpp/rpp/sources/error.hpp:52

Methodexchange_observers_under_lock_if_there

src/rpp/rpp/subjects/details/subject_state.hpp:178

Methodfinally_action

src/rpp/rpp/utils/utils.hpp:122

Methodfinish_writes

src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:138

Methodfinish_writes

src/extensions/rppgrpc/rppgrpc/server_reactor.hpp:64

Methodfinish_writes

src/extensions/rppgrpc/rppgrpc/server_reactor.hpp:138

Methodforwarding_subject

src/rpp/rpp/operators/details/forwarding_subject.hpp:47

Functionforwarding_subscribe

src/rpp/rpp/observables/dynamic_observable.hpp:24

Methodfrom_iterable_strategy

src/rpp/rpp/sources/from.hpp:90

src/rpp/rpp/disposables/disposable_wrapper.hpp:88

Methodget_advanced_call_handler

src/rpp/rpp/schedulers/details/queue.hpp:97

Methodget_disposable

src/rpp/rpp/subjects/behavior_subject.hpp:97

Methodget_disposable

src/rpp/rpp/subjects/publish_subject.hpp:56

Methodget_observable

src/rpp/rpp/operators/details/forwarding_subject.hpp:57

Methodget_observable

src/rpp/rpp/subjects/behavior_subject.hpp:84

Methodget_observable

src/rpp/rpp/subjects/publish_subject.hpp:51

Methodget_observer

src/rpp/rpp/operators/details/forwarding_subject.hpp:52

Methodget_observer

src/rpp/rpp/subjects/behavior_subject.hpp:79

Methodget_observer

src/rpp/rpp/subjects/publish_subject.hpp:46

Methodget_value

src/rpp/rpp/subjects/behavior_subject.hpp:39

Methodgrouped_observable

src/rpp/rpp/observables/grouped_observable.hpp:30

Methodhandle_observable_impl

src/rpp/rpp/operators/concat.hpp:82

Methodhandle_on_done

src/extensions/rppgrpc/rppgrpc/details/base.hpp:46

← previous next →401–500 of 973, ranked by callers