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

↓ 7 callersMethodapply

src/rpp/rpp/operators/merge.hpp:189

↓ 7 callersMethodend

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

↓ 7 callersFunctionfrom_callable

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

↓ 7 callersFunctionfrom_signal

src/extensions/rppqt/rppqt/sources/from_signal.hpp:76

↓ 7 callersMethodget_state_under_lock

src/rpp/rpp/operators/window_toggle.hpp:53

↓ 7 callersMethodis_any_ready_schedulable

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

↓ 7 callersMethodis_disposed

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

↓ 7 callersMethodon_error

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

↓ 7 callersFunctionref_count

* @brief Forces rpp::connectable_observable to behave like common observable * @details Connects rpp::connectable_observable on the first subscri

src/rpp/rpp/operators/ref_count.hpp:29

↓ 7 callersMethodref_count

* @brief Forces rpp::connectable_observable to behave like common observable * @details Connects rpp::connectable_observable on the first sub

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

↓ 7 callersFunctionstart_with

src/rpp/rpp/operators/start_with.hpp:89

↓ 7 callersFunctiontap

src/rpp/rpp/operators/tap.hpp:94

↓ 6 callersMethodbegin

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

↓ 6 callersMethodget_observable_for_move

src/tests/utils/copy_count_tracker.hpp:74

↓ 6 callersMethodget_observer

src/rpp/rpp/operators/switch_on_next.hpp:38

↓ 6 callersMethodget_observer_under_lock

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

↓ 6 callersMethodget_observer_with_timeout_under_lock

src/rpp/rpp/operators/timeout.hpp:38

↓ 6 callersFunctionmake_callback_disposable

src/rpp/rpp/disposables/callback_disposable.hpp:47

↓ 6 callersMethodremove

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

↓ 6 callersFunctionsubscribe_with_disposable

src/rpp/rpp/operators/subscribe.hpp:363

↓ 6 callersMethodwrapper_from_this

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

↓ 5 callersFunctiondebounce

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

↓ 5 callersMethoddefer_to

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

↓ 5 callersFunctiondistinct

* @brief For each item from this observable, filter out repeated values and emit only items that have not already been emitted * * @marble d

src/rpp/rpp/operators/distinct.hpp:86

↓ 5 callersFunctionfind_argument

src/benchmarks/benchmarks.cpp:46

↓ 5 callersMethodget_disposable

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

↓ 5 callersMethodget_inner_child_disposable

src/rpp/rpp/operators/switch_on_next.hpp:40

↓ 5 callersMethodget_observer

src/rpp/rpp/operators/take_until.hpp:39

↓ 5 callersMethodget_observer_under_lock

src/rpp/rpp/operators/with_latest_from.hpp:35

↓ 5 callersMethodget_observer_under_lock

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

↓ 5 callersMethodget_value

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

↓ 5 callersFunctiongroup_by

(data, key_selector)

ci/process_benchmark_data.py:6

↓ 5 callersMethodis_disposed

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

↓ 5 callersMethodnow

src/tests/rpp/test_delay.cpp:41

↓ 5 callersMethodon_completed

src/rpp/rpp/observers/fwd.hpp:230

↓ 5 callersMethodon_error

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

↓ 5 callersMethodon_error

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

↓ 5 callersMethodon_error

src/rpp/rpp/observers/fwd.hpp:228

↓ 5 callersFunctiontimer

src/rpp/rpp/sources/timer.hpp:25

↓ 5 callersMethodunlock

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

↓ 4 callersFunctionconcat

* @brief Make observable which would merge emissions from underlying observables but without overlapping (current observable completes THEN next start

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

↓ 4 callersMethoddefer_for

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

↓ 4 callersMethoddefer_with_time

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

↓ 4 callersFunctionfor_each

src/rpp/rpp/utils/utils.hpp:82

↓ 4 callersMethodget_on_next_const_ref_count

src/rpp/rpp/observers/mock_observer.hpp:51

↓ 4 callersMethodget_on_next_move_count

src/rpp/rpp/observers/mock_observer.hpp:52

↓ 4 callersMethodhandle_advanced_call

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

↓ 4 callersMethodis_disposed

src/rpp/rpp/operators/timeout.hpp:76

↓ 4 callersMethodis_disposed

src/rpp/rpp/operators/switch_on_next.hpp:135

↓ 4 callersMethodlock

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

↓ 4 callersMethodnow

src/rpp/rpp/schedulers/details/worker.hpp:59

↓ 4 callersMethodon_completed

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

↓ 4 callersMethodon_error

src/rpp/rpp/operators/window_toggle.hpp:166

↓ 4 callersMethodon_next

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

↓ 4 callersFunctionprint_metric

ci/process_benchmark_data.py:27

↓ 4 callersMethodset_upstream

src/rpp/rpp/observers/fwd.hpp:232

↓ 4 callersFunctionsleep_until

src/rpp/rpp/schedulers/details/utils.hpp:27

↓ 3 callersMethodServerSide

src/examples/rppgrpc/communication/server.cpp:39

↓ 3 callersMethodas_dynamic

* @brief Convert observable to type-erased version */

src/rpp/rpp/observables/observable.hpp:314

↓ 3 callersMethoddispatch

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

↓ 3 callersMethoddispatch_if_ready

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

↓ 3 callersFunctiondrain

src/rpp/rpp/operators/retry.hpp:84

↓ 3 callersFunctiondrain

src/tests/rppasio/test_rppasio_scheduler.cpp:33

↓ 3 callersMethodget_observer_under_lock

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

↓ 3 callersMethodis_disposed

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

↓ 3 callersMethodis_disposed

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

↓ 3 callersMethodmake_advanced_call

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

↓ 3 callersMethodon_error

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

↓ 3 callersMethodon_next

src/rpp/rpp/operators/merge.hpp:121

↓ 3 callersMethodon_next

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

↓ 3 callersMethodon_subscribe

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

↓ 3 callersMethodschedule

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

↓ 3 callersMethodset_upstream

src/rpp/rpp/operators/map.hpp:40

↓ 3 callersMethodstop_return_was_stopped

src/rpp/rpp/operators/take_until.hpp:37

↓ 3 callersMethodwait

src/rpp/rpp/observables/blocking_observable.hpp:25

↓ 2 callersMethodBidirectional

src/examples/rppgrpc/communication/server.cpp:18

↓ 2 callersMethodClientSide

src/examples/rppgrpc/communication/server.cpp:34

↓ 2 callersMethodapply

src/rpp/rpp/operators/details/strategy.hpp:46

↓ 2 callersMethodas_dynamic_connectable

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

↓ 2 callersMethodclear

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

↓ 2 callersFunctiondrain

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

↓ 2 callersMethoddrain

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

↓ 2 callersMethodemit_single_value_signal

src/tests/rppqt/test_from_signal.cpp:20

↓ 2 callersMethodemplace_and_notify

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

↓ 2 callersMethodfinish_writes

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

↓ 2 callersFunctionformat_message

src/examples/rpp/two_async_streams/two_async_streams.cpp:10

↓ 2 callersMethodget_disposable

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

↓ 2 callersMethodget_disposable

src/tests/rpp/test_delay.cpp:40

↓ 2 callersMethodget_next

src/rpp/rpp/operators/take_last.hpp:71

↓ 2 callersMethodget_observer

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

↓ 2 callersFunctionget_presents_stream

src/examples/rpp/sfml/snake/utils.hpp:35

↓ 2 callersFunctionget_rectangle_at

src/examples/rpp/sfml/snake/canvas.cpp:9

↓ 2 callersMethodis_disposed

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

↓ 2 callersMethodis_disposed

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

↓ 2 callersMethodis_disposed

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

↓ 2 callersMethodis_disposed

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

↓ 2 callersFunctionjson

src/benchmarks/benchmarks.cpp:32

↓ 2 callersMethodon_completed

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

↓ 2 callersMethodon_error

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

↓ 2 callersMethodon_new_subject

src/rpp/rpp/operators/window_toggle.hpp:61

← previous next →101–200 of 973, ranked by callers