MCPcopy Create free account

hub / github.com/AlexInLog/ReactivePlusPlus / functions

Functions973 in github.com/AlexInLog/ReactivePlusPlus

↓ 2 callersMethodon_next
src/rpp/rpp/operators/group_by.hpp:94
↓ 2 callersMethodon_next
src/rpp/rpp/operators/reduce.hpp:31
↓ 2 callersMethodon_next
src/rpp/rpp/operators/debounce.hpp:129
↓ 2 callersMethodpipe
src/rpp/rpp/observables/observable.hpp:361
↓ 2 callersMethodset_next
src/rpp/rpp/schedulers/details/queue.hpp:86
↓ 2 callersMethodset_timepoint
src/rpp/rpp/schedulers/details/queue.hpp:82
↓ 2 callersMethodset_upstream
src/rpp/rpp/operators/group_by.hpp:83
↓ 2 callersMethodset_upstream
src/rpp/rpp/operators/on_error_resume_next.hpp:99
↓ 2 callersMethodset_upstream
src/rpp/rpp/observers/dynamic_observer.hpp:26
↓ 2 callersFunctionsimulate_complex_scheduling
src/tests/rpp/test_scheduler.cpp:74
↓ 2 callersFunctionsimulate_complex_scheduling_with_delay
src/tests/rpp/test_scheduler.cpp:119
↓ 2 callersFunctionsimulate_nested_scheduling
src/tests/rpp/test_scheduler.cpp:43
↓ 2 callersMethodsubscribe
src/rpp/rpp/observables/fwd.hpp:60
↓ 2 callersFunctionthrottle
src/rpp/rpp/operators/throttle.hpp:102
↓ 2 callersMethodunlock
src/rpp/rpp/utils/utils.hpp:254
↓ 2 callersFunctionwrap_coordinate
src/examples/rpp/sfml/snake/snake.cpp:23
↓ 1 callersMethodBidirectional
[bidi_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:25
↓ 1 callersMethodClientSide
[read_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:16
↓ 1 callersMethodServerSide
[write_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:37
↓ 1 callersMethodadd_value
src/rpp/rpp/subjects/replay_subject.hpp:36
↓ 1 callersMethodapply
src/rpp/rpp/operators/start_with.hpp:34
↓ 1 callersMethodcan_run_immediately
src/rpp/rpp/schedulers/details/queue.hpp:59
↓ 1 callersMethodclear
src/rpp/rpp/disposables/composite_disposable.hpp:125
↓ 1 callersMethodcreate_worker
src/extensions/rppasio/rppasio/schedulers/strand.hpp:183
↓ 1 callersMethoddecrement_on_completed
just need atomicity, not guarding anything
src/rpp/rpp/operators/merge.hpp:39
↓ 1 callersMethoddecrement_on_completed
src/rpp/rpp/operators/details/combining_strategy.hpp:37
↓ 1 callersMethoddefer
src/extensions/rppasio/rppasio/schedulers/strand.hpp:45
↓ 1 callersMethoddispose
src/rpp/rpp/disposables/disposable_wrapper.hpp:69
↓ 1 callersMethoddispose
src/rpp/rpp/disposables/details/container.hpp:126
↓ 1 callersMethoddispose_impl
src/rpp/rpp/disposables/details/base_disposable.hpp:36
↓ 1 callersMethoddrain
src/rpp/rpp/operators/concat.hpp:52
↓ 1 callersMethodemit_multiple_value_signal
src/tests/rppqt/test_from_signal.cpp:25
↓ 1 callersMethodemit_no_value_signal
src/tests/rppqt/test_from_signal.cpp:30
↓ 1 callersMethodemplace_safe
src/rpp/rpp/operators/debounce.hpp:49
↓ 1 callersMethodextract_value
src/rpp/rpp/operators/debounce.hpp:61
↓ 1 callersMethodextract_value_or_time
src/rpp/rpp/operators/debounce.hpp:87
↓ 1 callersFunctiongenerate_initial_apple
src/examples/rpp/sfml/snake/snake.cpp:18
↓ 1 callersFunctiongenerate_initial_snake_body
src/examples/rpp/sfml/snake/snake.cpp:12
↓ 1 callersFunctiongenerate_svg
(name, text)
ci/generate_marbles.py:13
↓ 1 callersMethodget
src/rpp/rpp/disposables/details/container.hpp:142
↓ 1 callersMethodget_actual_values
src/rpp/rpp/subjects/replay_subject.hpp:58
↓ 1 callersMethodget_closing
src/rpp/rpp/operators/window_toggle.hpp:56
↓ 1 callersFunctionget_events_observable
src/examples/rpp/sfml/snake/main.cpp:11
↓ 1 callersMethodget_observable
src/rpp/rpp/subjects/replay_subject.hpp:129
↓ 1 callersMethodget_observer
src/rpp/rpp/observers/mock_observer.hpp:58
↓ 1 callersMethodget_period
src/rpp/rpp/operators/timeout.hpp:42
↓ 1 callersMethodget_queue
src/rpp/rpp/operators/concat.hpp:48
↓ 1 callersFunctionget_shapes_to_draw
src/examples/rpp/sfml/snake/snake.cpp:77
↓ 1 callersFunctionget_window_size
src/examples/rpp/sfml/snake/canvas.cpp:18
↓ 1 callersMethodhandle_observable
src/rpp/rpp/operators/concat.hpp:70
↓ 1 callersMethodincrement_on_completed
just need atomicity, not guarding anything
src/rpp/rpp/operators/merge.hpp:36
↓ 1 callersFunctionindent
(l)
ci/find_longest_symbols.py:2
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/delay.hpp:80
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/retry.hpp:80
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/window_toggle.hpp:184
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/scan.hpp:48
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/with_latest_from.hpp:93
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/reduce.hpp:46
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/on_error_resume_next.hpp:104
↓ 1 callersMethodis_disposed
src/rpp/rpp/operators/debounce.hpp:123
↓ 1 callersMethodis_disposed
src/rpp/rpp/disposables/composite_disposable.hpp:37
↓ 1 callersMethodis_disposed
src/rpp/rpp/observers/details/disposables_strategy.hpp:54
↓ 1 callersMethodis_disposed
src/rpp/rpp/subjects/behavior_subject.hpp:53
↓ 1 callersMethodis_stopped
src/rpp/rpp/operators/take_until.hpp:36
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/delay.hpp:97
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/take_until.hpp:59
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/first.hpp:34
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/window_toggle.hpp:174
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/merge.hpp:78
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/take_while.hpp:39
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/scan.hpp:44
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/switch_on_next.hpp:127
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/take.hpp:45
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/group_by.hpp:109
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/reduce.hpp:38
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/concat.hpp:178
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/window.hpp:79
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/on_error_resume_next.hpp:94
↓ 1 callersMethodon_completed
src/rpp/rpp/operators/element_at.hpp:48
↓ 1 callersMethodon_completed
src/rpp/rpp/subjects/details/subject_state.hpp:142
↓ 1 callersMethodon_error
src/rpp/rpp/operators/retry.hpp:54
↓ 1 callersMethodon_error
src/rpp/rpp/operators/last.hpp:47
↓ 1 callersMethodon_error
src/rpp/rpp/operators/timeout.hpp:89
↓ 1 callersMethodon_error
src/rpp/rpp/operators/first.hpp:39
↓ 1 callersMethodon_error
src/rpp/rpp/operators/scan.hpp:42
↓ 1 callersMethodon_error
src/rpp/rpp/operators/repeat_when.hpp:35
↓ 1 callersMethodon_error
src/rpp/rpp/operators/switch_on_next.hpp:122
↓ 1 callersMethodon_error
src/rpp/rpp/operators/with_latest_from.hpp:113
↓ 1 callersMethodon_error
src/rpp/rpp/operators/group_by.hpp:101
↓ 1 callersMethodon_error
src/rpp/rpp/operators/reduce.hpp:36
↓ 1 callersMethodon_error
src/rpp/rpp/operators/concat.hpp:173
↓ 1 callersMethodon_error
src/rpp/rpp/operators/on_error_resume_next.hpp:81
↓ 1 callersMethodon_error
src/rpp/rpp/operators/debounce.hpp:134
↓ 1 callersMethodon_error
src/rpp/rpp/operators/element_at.hpp:46
↓ 1 callersMethodon_error
src/rpp/rpp/operators/details/repeating_strategy.hpp:70
↓ 1 callersMethodon_error
src/rpp/rpp/schedulers/fwd.hpp:90
↓ 1 callersMethodon_error
src/rpp/rpp/subjects/details/subject_state.hpp:132
↓ 1 callersMethodon_next
src/rpp/rpp/operators/delay.hpp:86
↓ 1 callersMethodon_next
src/rpp/rpp/operators/last.hpp:31
↓ 1 callersMethodon_next
src/rpp/rpp/operators/combine_latest.hpp:48
← previousnext →201–300 of 973, ranked by callers