Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/AlexInLog/ReactivePlusPlus
/ functions
Functions
973 in github.com/AlexInLog/ReactivePlusPlus
⨍
Functions
973
◇
Types & classes
437
↓ 2 callers
Method
on_next
src/rpp/rpp/operators/group_by.hpp:94
↓ 2 callers
Method
on_next
src/rpp/rpp/operators/reduce.hpp:31
↓ 2 callers
Method
on_next
src/rpp/rpp/operators/debounce.hpp:129
↓ 2 callers
Method
pipe
src/rpp/rpp/observables/observable.hpp:361
↓ 2 callers
Method
set_next
src/rpp/rpp/schedulers/details/queue.hpp:86
↓ 2 callers
Method
set_timepoint
src/rpp/rpp/schedulers/details/queue.hpp:82
↓ 2 callers
Method
set_upstream
src/rpp/rpp/operators/group_by.hpp:83
↓ 2 callers
Method
set_upstream
src/rpp/rpp/operators/on_error_resume_next.hpp:99
↓ 2 callers
Method
set_upstream
src/rpp/rpp/observers/dynamic_observer.hpp:26
↓ 2 callers
Function
simulate_complex_scheduling
src/tests/rpp/test_scheduler.cpp:74
↓ 2 callers
Function
simulate_complex_scheduling_with_delay
src/tests/rpp/test_scheduler.cpp:119
↓ 2 callers
Function
simulate_nested_scheduling
src/tests/rpp/test_scheduler.cpp:43
↓ 2 callers
Method
subscribe
src/rpp/rpp/observables/fwd.hpp:60
↓ 2 callers
Function
throttle
src/rpp/rpp/operators/throttle.hpp:102
↓ 2 callers
Method
unlock
src/rpp/rpp/utils/utils.hpp:254
↓ 2 callers
Function
wrap_coordinate
src/examples/rpp/sfml/snake/snake.cpp:23
↓ 1 callers
Method
Bidirectional
[bidi_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:25
↓ 1 callers
Method
ClientSide
[read_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:16
↓ 1 callers
Method
ServerSide
[write_reactor]
src/examples/rppgrpc/doxygen/server_reactor.cpp:37
↓ 1 callers
Method
add_value
src/rpp/rpp/subjects/replay_subject.hpp:36
↓ 1 callers
Method
apply
src/rpp/rpp/operators/start_with.hpp:34
↓ 1 callers
Method
can_run_immediately
src/rpp/rpp/schedulers/details/queue.hpp:59
↓ 1 callers
Method
clear
src/rpp/rpp/disposables/composite_disposable.hpp:125
↓ 1 callers
Method
create_worker
src/extensions/rppasio/rppasio/schedulers/strand.hpp:183
↓ 1 callers
Method
decrement_on_completed
just need atomicity, not guarding anything
src/rpp/rpp/operators/merge.hpp:39
↓ 1 callers
Method
decrement_on_completed
src/rpp/rpp/operators/details/combining_strategy.hpp:37
↓ 1 callers
Method
defer
src/extensions/rppasio/rppasio/schedulers/strand.hpp:45
↓ 1 callers
Method
dispose
src/rpp/rpp/disposables/disposable_wrapper.hpp:69
↓ 1 callers
Method
dispose
src/rpp/rpp/disposables/details/container.hpp:126
↓ 1 callers
Method
dispose_impl
src/rpp/rpp/disposables/details/base_disposable.hpp:36
↓ 1 callers
Method
drain
src/rpp/rpp/operators/concat.hpp:52
↓ 1 callers
Method
emit_multiple_value_signal
src/tests/rppqt/test_from_signal.cpp:25
↓ 1 callers
Method
emit_no_value_signal
src/tests/rppqt/test_from_signal.cpp:30
↓ 1 callers
Method
emplace_safe
src/rpp/rpp/operators/debounce.hpp:49
↓ 1 callers
Method
extract_value
src/rpp/rpp/operators/debounce.hpp:61
↓ 1 callers
Method
extract_value_or_time
src/rpp/rpp/operators/debounce.hpp:87
↓ 1 callers
Function
generate_initial_apple
src/examples/rpp/sfml/snake/snake.cpp:18
↓ 1 callers
Function
generate_initial_snake_body
src/examples/rpp/sfml/snake/snake.cpp:12
↓ 1 callers
Function
generate_svg
(name, text)
ci/generate_marbles.py:13
↓ 1 callers
Method
get
src/rpp/rpp/disposables/details/container.hpp:142
↓ 1 callers
Method
get_actual_values
src/rpp/rpp/subjects/replay_subject.hpp:58
↓ 1 callers
Method
get_closing
src/rpp/rpp/operators/window_toggle.hpp:56
↓ 1 callers
Function
get_events_observable
src/examples/rpp/sfml/snake/main.cpp:11
↓ 1 callers
Method
get_observable
src/rpp/rpp/subjects/replay_subject.hpp:129
↓ 1 callers
Method
get_observer
src/rpp/rpp/observers/mock_observer.hpp:58
↓ 1 callers
Method
get_period
src/rpp/rpp/operators/timeout.hpp:42
↓ 1 callers
Method
get_queue
src/rpp/rpp/operators/concat.hpp:48
↓ 1 callers
Function
get_shapes_to_draw
src/examples/rpp/sfml/snake/snake.cpp:77
↓ 1 callers
Function
get_window_size
src/examples/rpp/sfml/snake/canvas.cpp:18
↓ 1 callers
Method
handle_observable
src/rpp/rpp/operators/concat.hpp:70
↓ 1 callers
Method
increment_on_completed
just need atomicity, not guarding anything
src/rpp/rpp/operators/merge.hpp:36
↓ 1 callers
Function
indent
(l)
ci/find_longest_symbols.py:2
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/delay.hpp:80
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/retry.hpp:80
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/window_toggle.hpp:184
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/scan.hpp:48
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/with_latest_from.hpp:93
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/reduce.hpp:46
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/on_error_resume_next.hpp:104
↓ 1 callers
Method
is_disposed
src/rpp/rpp/operators/debounce.hpp:123
↓ 1 callers
Method
is_disposed
src/rpp/rpp/disposables/composite_disposable.hpp:37
↓ 1 callers
Method
is_disposed
src/rpp/rpp/observers/details/disposables_strategy.hpp:54
↓ 1 callers
Method
is_disposed
src/rpp/rpp/subjects/behavior_subject.hpp:53
↓ 1 callers
Method
is_stopped
src/rpp/rpp/operators/take_until.hpp:36
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/delay.hpp:97
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/take_until.hpp:59
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/first.hpp:34
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/window_toggle.hpp:174
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/merge.hpp:78
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/take_while.hpp:39
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/scan.hpp:44
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/switch_on_next.hpp:127
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/take.hpp:45
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/group_by.hpp:109
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/reduce.hpp:38
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/concat.hpp:178
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/window.hpp:79
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/on_error_resume_next.hpp:94
↓ 1 callers
Method
on_completed
src/rpp/rpp/operators/element_at.hpp:48
↓ 1 callers
Method
on_completed
src/rpp/rpp/subjects/details/subject_state.hpp:142
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/retry.hpp:54
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/last.hpp:47
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/timeout.hpp:89
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/first.hpp:39
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/scan.hpp:42
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/repeat_when.hpp:35
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/switch_on_next.hpp:122
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/with_latest_from.hpp:113
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/group_by.hpp:101
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/reduce.hpp:36
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/concat.hpp:173
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/on_error_resume_next.hpp:81
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/debounce.hpp:134
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/element_at.hpp:46
↓ 1 callers
Method
on_error
src/rpp/rpp/operators/details/repeating_strategy.hpp:70
↓ 1 callers
Method
on_error
src/rpp/rpp/schedulers/fwd.hpp:90
↓ 1 callers
Method
on_error
src/rpp/rpp/subjects/details/subject_state.hpp:132
↓ 1 callers
Method
on_next
src/rpp/rpp/operators/delay.hpp:86
↓ 1 callers
Method
on_next
src/rpp/rpp/operators/last.hpp:31
↓ 1 callers
Method
on_next
src/rpp/rpp/operators/combine_latest.hpp:48
← previous
next →
201–300 of 973, ranked by callers