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

↓ 384 callersFunctionsubscribe

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

↓ 272 callersMethodget_on_completed_count

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

↓ 252 callersMethodget_on_error_count

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

↓ 250 callersFunctionjust

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

↓ 239 callersMethodis_disposed

src/tests/rpp/test_disposables.cpp:22

↓ 231 callersMethodget_received_values

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

↓ 191 callersMethodget_observer

src/tests/utils/rpp_trompeloil.hpp:49

↓ 159 callersMethodsubscribe

src/tests/utils/disposable_observable.hpp:33

↓ 157 callersMethodon_next

src/tests/utils/rpp_trompeloil.hpp:33

↓ 116 callersFunctionmap

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

↓ 101 callersMethodas_dynamic

* @brief Convert current observer to type-erased version. Useful if you need to COPY your observer or to store different observers in same container.

src/rpp/rpp/observers/observer.hpp:197

↓ 99 callersMethodget_total_on_next_count

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

↓ 93 callersFunctionnow

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

↓ 87 callersMethodschedule

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

↓ 84 callersMethodsubscribe

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

↓ 75 callersMethodon_completed

src/tests/utils/rpp_trompeloil.hpp:44

↓ 72 callersMethodget_observable

src/tests/utils/copy_count_tracker.hpp:65

↓ 67 callersMethoddispose

* @brief Dispose disposable and free any underlying resources and etc. * @attention This function must be thread-safe */

src/rpp/rpp/disposables/interface_disposable.hpp:36

↓ 64 callersFunctionimmediate_just

src/benchmarks/benchmarks.cpp:62

↓ 62 callersMethodpush_back

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

↓ 55 callersMethodon_error

src/tests/utils/rpp_trompeloil.hpp:43

↓ 44 callersMethodempty

* @brief Creates disposable_wrapper which behaves like disposed disposable */

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

↓ 43 callersMethodget

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

↓ 42 callersMethodlock

src/rpp/rpp/utils/utils.hpp:253

↓ 36 callersFunctionconcat

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

↓ 36 callersFunctionfilter

src/rpp/rpp/operators/filter.hpp:95

↓ 34 callersFunctionas_blocking

* @brief Converts `rpp::observable` to `rpp::blocking_observable` * @details `rpp::blocking_observable` blocks `subscribe` call till on_completed

src/rpp/rpp/operators/as_blocking.hpp:47

↓ 32 callersFunctionempty

src/rpp/rpp/sources/empty.hpp:51

↓ 32 callersFunctiontake

* @brief Emit only first `count` items provided by observable, then send `on_completed` * * @marble take { source observable

src/rpp/rpp/operators/take.hpp:96

↓ 32 callersMethodtime_advance

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

↓ 30 callersMethodget_copy_count

src/tests/utils/copy_count_tracker.hpp:114

↓ 30 callersMethodget_move_count

src/tests/utils/copy_count_tracker.hpp:115

↓ 29 callersMethodset_upstream

src/tests/utils/rpp_trompeloil.hpp:47

↓ 28 callersMethodadd

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

↓ 26 callersFunctionwait

src/tests/utils/rpp_trompeloil.hpp:57

↓ 24 callersFunctiontest

src/examples/rpp/doxygen/readme.cpp:52

↓ 23 callersFunctionget_thread_id_as_string

src/tests/rpp/test_scheduler.cpp:36

↓ 22 callersFunctionflat_map

src/rpp/rpp/operators/flat_map.hpp:68

↓ 22 callersFunctionretry

* @brief The retry operator attempts to resubscribe to the observable when an error occurs, up to the specified number of retries. * * @marb

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

↓ 21 callersMethodon_next

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

↓ 21 callersFunctionscan

src/rpp/rpp/operators/scan.hpp:155

↓ 20 callersMethodas_weak

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

↓ 20 callersFunctiondelay

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

↓ 20 callersMethodinit

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

↓ 20 callersFunctionretry_when

src/rpp/rpp/operators/retry_when.hpp:105

↓ 20 callersFunctiontake_while

src/rpp/rpp/operators/take_while.hpp:95

↓ 19 callersMethodget_observable

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

↓ 19 callersFunctioninterval

src/rpp/rpp/sources/interval.hpp:75

↓ 19 callersMethodis_empty

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

↓ 18 callersMethodget_observer

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

↓ 17 callersMethodadd

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

↓ 17 callersMethodget_observable

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

↓ 16 callersMethoddispose

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

↓ 16 callersFunctionfrom_iterable

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

↓ 16 callersFunctionmerge

* @brief Converts observable of observables of items into observable of items via merging emissions. * * @invariant According to observable

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

↓ 16 callersFunctionrepeat

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

↓ 15 callersMethodclear

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

↓ 15 callersFunctionmerge_with

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

↓ 15 callersFunctionreduce

src/rpp/rpp/operators/reduce.hpp:147

↓ 15 callersFunctiontake_until

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

↓ 15 callersFunctionwindow_toggle

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

↓ 15 callersFunctionwith_latest_from

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

↓ 14 callersMethodget_timepoint

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

↓ 14 callersMethodlock

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

↓ 14 callersMethodon_next

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

↓ 14 callersFunctionswitch_on_next

* @brief Converts observable of observables into observable of values which emits values from most recent underlying observable till new observable ob

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

↓ 14 callersFunctiontake_last

* @brief Emit only last `count` items provided by observable, then send `on_completed` * * @marble take_last { source observab

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

↓ 13 callersFunctionbuffer

* @brief Periodically gather emissions emitted by an original Observable into bundles and emit these bundles rather than emitting * the items one

src/rpp/rpp/operators/buffer.hpp:111

↓ 13 callersMethodconnect

* @brief Connects to underlying observable right-now making it hot-observable * * @par Example: * @snippet connect.cpp conn

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

↓ 13 callersMethodemplace

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

↓ 13 callersMethodis_disposed

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

↓ 12 callersFunctiondistinct_until_changed

src/rpp/rpp/operators/distinct_until_changed.hpp:101

↓ 12 callersFunctiongroup_by

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

↓ 12 callersFunctionskip

* @brief Skip first `count` items provided by observable then send rest items as expected * * @marble skip { source observable

src/rpp/rpp/operators/skip.hpp:93

↓ 12 callersFunctionsubscribe_on

src/rpp/rpp/operators/subscribe_on.hpp:75

↓ 12 callersFunctiontimeout

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

↓ 12 callersFunctionzip

src/rpp/rpp/operators/zip.hpp:103

↓ 11 callersMethodcreate_worker

src/tests/rpp/test_delay.cpp:44

↓ 11 callersFunctionfirst

* @brief Emit only the first item. * * @marble first { source observable : +--1--2--3--| operator "firs

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

↓ 11 callersMethodget_observer

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

↓ 11 callersFunctionlast

* @brief Emit only the last item provided before on_completed. * * @marble last { source observable : +--1--2--3--|

src/rpp/rpp/operators/last.hpp:99

↓ 10 callersMethodadd_ref

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

↓ 10 callersFunctioncombine_latest

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

↓ 10 callersFunctionelement_at

* @brief Emit item located at specified `index` location in the sequence of items emitted by the source observable * * @marble element_at

src/rpp/rpp/operators/element_at.hpp:101

↓ 10 callersMethodis_disposed

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

↓ 10 callersFunctionmake_lambda_observer

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

↓ 10 callersFunctionon_error_resume_next

src/rpp/rpp/operators/on_error_resume_next.hpp:161

↓ 10 callersFunctionrepeat_when

src/rpp/rpp/operators/repeat_when.hpp:96

↓ 9 callersFunctiondefer

src/rpp/rpp/sources/defer.hpp:57

↓ 9 callersMethodemplace

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

↓ 9 callersFunctionmulticast

src/rpp/rpp/operators/multicast.hpp:65

↓ 9 callersFunctionobserve_on

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

↓ 9 callersFunctionpublish

* @brief Converts ordinary observable to rpp::connectable_observable with help of inline instsantiated publish subject * @details Connectable obs

src/rpp/rpp/operators/publish.hpp:22

↓ 8 callersFunctionall_of

src/rpp/rpp/utils/utils.hpp:88

↓ 8 callersMethodcreate_worker

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

↓ 8 callersFunctionfinally

src/rpp/rpp/operators/finally.hpp:57

↓ 8 callersMethodis_disposed

src/tests/utils/rpp_trompeloil.hpp:46

↓ 8 callersMethodon_completed

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

↓ 8 callersMethodpop

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

↓ 8 callersFunctionwindow

* @brief Subdivide original observable into sub-observables (window observables) and emit sub-observables of items instead of original items *

src/rpp/rpp/operators/window.hpp:160

next →1–100 of 973, ranked by callers