MCPcopy Create free account

hub / github.com/AlexInLog/ReactivePlusPlus / functions

Functions973 in github.com/AlexInLog/ReactivePlusPlus

Methodhandle_on_done
src/extensions/rppgrpc/rppgrpc/details/base.hpp:132
Methodhandle_read_done
src/extensions/rppgrpc/rppgrpc/details/base.hpp:125
Methodhandle_write_done
src/extensions/rppgrpc/rppgrpc/details/base.hpp:51
Functionimmediate_scheduling_while_condition
src/rpp/rpp/schedulers/details/utils.hpp:43
Methodimpl_t
src/tests/utils/rpp_trompeloil.hpp:23
Methodinfinite_repeated_container
src/rpp/rpp/utils/utils.hpp:207
Methodinit
src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:120
Methodinit
src/extensions/rppgrpc/rppgrpc/client_reactor.hpp:183
Methodinit_state
src/rpp/rpp/operators/merge.hpp:128
Methodinit_state
src/rpp/rpp/operators/switch_on_next.hpp:138
Methodinit_state
src/rpp/rpp/operators/concat.hpp:190
Methodinit_state
src/rpp/rpp/operators/on_error_resume_next.hpp:106
Methodinvoke
src/extensions/rppqt/rppqt/schedulers/main_thread.hpp:57
Methodis_any_ready_schedulable
src/rpp/rpp/schedulers/run_loop.hpp:74
Methodis_any_ready_schedulable_unsafe
src/rpp/rpp/schedulers/run_loop.hpp:87
Methodis_disposed
src/rpp/rpp/operators/delay.hpp:64
Methodis_disposed
src/rpp/rpp/operators/last.hpp:51
Methodis_disposed
src/rpp/rpp/operators/filter.hpp:43
Methodis_disposed
src/rpp/rpp/operators/take_until.hpp:67
Methodis_disposed
src/rpp/rpp/operators/map.hpp:42
Methodis_disposed
src/rpp/rpp/operators/timeout.hpp:56
Methodis_disposed
src/rpp/rpp/operators/buffer.hpp:63
Methodis_disposed
src/rpp/rpp/operators/take_last.hpp:68
Methodis_disposed
src/rpp/rpp/operators/first.hpp:43
Methodis_disposed
src/rpp/rpp/operators/window_toggle.hpp:109
Methodis_disposed
src/rpp/rpp/operators/window_toggle.hpp:140
Methodis_disposed
src/rpp/rpp/operators/throttle.hpp:50
Methodis_disposed
src/rpp/rpp/operators/merge.hpp:68
Methodis_disposed
src/rpp/rpp/operators/tap.hpp:55
Methodis_disposed
src/rpp/rpp/operators/take_while.hpp:43
Methodis_disposed
src/rpp/rpp/operators/scan.hpp:99
Methodis_disposed
src/rpp/rpp/operators/distinct_until_changed.hpp:47
Methodis_disposed
src/rpp/rpp/operators/switch_on_next.hpp:86
Methodis_disposed
src/rpp/rpp/operators/with_latest_from.hpp:58
Methodis_disposed
src/rpp/rpp/operators/distinct.hpp:47
Methodis_disposed
src/rpp/rpp/operators/take.hpp:49
Methodis_disposed
src/rpp/rpp/operators/group_by.hpp:56
Methodis_disposed
src/rpp/rpp/operators/reduce.hpp:99
Methodis_disposed
src/rpp/rpp/operators/concat.hpp:148
Methodis_disposed
src/rpp/rpp/operators/skip.hpp:45
Methodis_disposed
src/rpp/rpp/operators/window.hpp:88
Methodis_disposed
src/rpp/rpp/operators/on_error_resume_next.hpp:57
Methodis_disposed
src/rpp/rpp/operators/debounce.hpp:29
Methodis_disposed
src/rpp/rpp/operators/element_at.hpp:62
Methodis_disposed
src/rpp/rpp/operators/details/combining_strategy.hpp:62
Methodis_disposed
src/rpp/rpp/operators/details/forwarding_subject.hpp:35
Methodis_disposed
src/rpp/rpp/operators/details/repeating_strategy.hpp:84
Methodis_disposed
src/rpp/rpp/disposables/disposable_wrapper.hpp:62
Methodis_disposed
src/rpp/rpp/disposables/details/base_disposable.hpp:29
Methodis_disposed
src/rpp/rpp/observers/lambda_observer.hpp:41
Methodis_disposed
* @brief Observable calls this method to check if observer interested or not in emissions * * @return true if observer disposed and
src/rpp/rpp/observers/observer.hpp:74
Methodis_disposed
src/rpp/rpp/observers/fwd.hpp:90
Methodis_disposed
src/rpp/rpp/observers/mock_observer.hpp:47
Methodis_disposed
src/rpp/rpp/observers/dynamic_observer.hpp:102
Methodis_disposed
src/rpp/rpp/observers/details/disposables_strategy.hpp:34
Methodis_disposed
src/rpp/rpp/observers/details/disposables_strategy.hpp:64
Methodis_disposed
src/rpp/rpp/subjects/publish_subject.hpp:32
Methodis_disposed
src/rpp/rpp/subjects/replay_subject.hpp:93
Methodis_empty
src/rpp/rpp/schedulers/run_loop.hpp:80
Methodis_empty
src/rpp/rpp/schedulers/details/queue.hpp:237
Functionis_snake_eat_self
src/examples/rpp/sfml/snake/snake.cpp:51
Methoditerator
src/rpp/rpp/utils/utils.hpp:160
Methoditerator
src/rpp/rpp/utils/utils.hpp:220
Methoditerator
src/tests/rpp/test_concat.cpp:44
Methodlambda_strategy
src/rpp/rpp/observers/lambda_observer.hpp:28
Methodlift
src/rpp/rpp/operators/take_until.hpp:109
Methodlift
src/rpp/rpp/operators/with_latest_from.hpp:144
Methodlift
src/rpp/rpp/operators/finally.hpp:35
Methodlift
src/rpp/rpp/operators/details/combining_strategy.hpp:99
Methodlift
src/rpp/rpp/operators/details/strategy.hpp:37
Methodlift
src/examples/rpp/doxygen/readme.cpp:40
Methodlift_operator
src/rpp/rpp/operators/details/strategy.hpp:31
Methodlift_with_disposables_strategy
src/rpp/rpp/operators/delay.hpp:184
Methodlift_with_disposables_strategy
src/rpp/rpp/operators/timeout.hpp:125
Methodlift_with_disposables_strategy
src/rpp/rpp/operators/timeout.hpp:176
Methodlift_with_disposables_strategy
src/rpp/rpp/operators/debounce.hpp:164
Methodlocal_disposables_strategy
src/rpp/rpp/observers/details/disposables_strategy.hpp:26
Methodlock
src/rpp/rpp/utils/utils.hpp:303
Functionmain
src/examples/rppgrpc/doxygen/server_reactor.cpp:49
Functionmain
src/examples/rppgrpc/doxygen/client_reactor.cpp:11
Functionmain
src/examples/rppgrpc/communication/client.cpp:10
Functionmain
src/examples/rppgrpc/communication/server.cpp:53
Functionmain
src/examples/rpp/two_async_streams/two_async_streams.cpp:21
Functionmain
src/examples/rpp/long_chain/long_chain.cpp:8
Functionmain
src/examples/rpp/doxygen/concat.cpp:11
Functionmain
src/examples/rpp/doxygen/as_blocking.cpp:11
Functionmain
* @example retry.cpp **/
src/examples/rpp/doxygen/retry.cpp:9
Functionmain
* @example delay.cpp **/
src/examples/rpp/doxygen/delay.cpp:10
Functionmain
src/examples/rpp/doxygen/scan.cpp:9
Functionmain
* @example take_last.cpp **/
src/examples/rpp/doxygen/take_last.cpp:8
Functionmain
src/examples/rpp/doxygen/interval.cpp:10
Functionmain
src/examples/rpp/doxygen/defer.cpp:9
Functionmain
* @example take_until.cpp **/
src/examples/rpp/doxygen/take_until.cpp:9
Functionmain
* @example combine_latest.cpp **/
src/examples/rpp/doxygen/combine_latest.cpp:14
Functionmain
* @example filter.cpp **/
src/examples/rpp/doxygen/filter.cpp:8
Functionmain
* @example last.cpp **/
src/examples/rpp/doxygen/last.cpp:8
Functionmain
* @example multicast.cpp **/
src/examples/rpp/doxygen/multicast.cpp:8
Functionmain
* @example skip.cpp **/
src/examples/rpp/doxygen/skip.cpp:8
Functionmain
* @example subscribe_on.cpp **/
src/examples/rpp/doxygen/subscribe_on.cpp:8
Functionmain
* @example window.cpp **/
src/examples/rpp/doxygen/window.cpp:8
← previousnext →501–600 of 973, ranked by callers