Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ReactiveX/RxCpp
/ functions
Functions
1,624 in github.com/ReactiveX/RxCpp
⨍
Functions
1,624
◇
Types & classes
987
↓ 3,842 callers
Method
next
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:389
↓ 1,075 callers
Function
to_vector
Rx/v2/src/rxcpp/rx-util.hpp:63
↓ 952 callers
Method
subscribe
Rx/v2/src/rxcpp/rx-observable.hpp:648
↓ 693 callers
Method
completed
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:393
↓ 607 callers
Method
subscriptions
Rx/v2/src/rxcpp/rx-test.hpp:101
↓ 520 callers
Method
make_hot_observable
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:574
↓ 459 callers
Method
messages
Rx/v2/src/rxcpp/rx-test.hpp:69
↓ 449 callers
Method
create_worker
create a worker with a lifetime. when the worker is unsubscribed all scheduled items will be unsubscribed. items scheduled to a worker will be run one
Rx/v2/src/rxcpp/rx-scheduler.hpp:412
↓ 443 callers
Method
start
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:466
↓ 441 callers
Function
make_test
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:604
↓ 412 callers
Method
as_dynamic
Rx/v2/src/rxcpp/rx-observer.hpp:253
↓ 279 callers
Method
error
Rx/v2/src/rxcpp/sources/rx-error.hpp:59
↓ 167 callers
Method
empty
Rx/v2/src/rxcpp/schedulers/rx-runloop.hpp:166
↓ 154 callers
Function
observable_member
Rx/v2/src/rxcpp/rx-operators.hpp:63
↓ 150 callers
Function
range
Rx/v2/src/rxcpp/sources/rx-range.hpp:119
↓ 148 callers
Function
get_pid
Rx/v2/examples/doxygen/main.cpp:10
↓ 122 callers
Method
make_cold_observable
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:591
↓ 115 callers
Method
map
Rx/v2/src/rxcpp/operators/rx-map.hpp:49
↓ 110 callers
Function
interval
Rx/v2/src/rxcpp/sources/rx-interval.hpp:113
↓ 106 callers
Function
on_exception
Rx/v2/src/rxcpp/rx-observer.hpp:640
↓ 106 callers
Method
take
Rx/v2/src/rxcpp/operators/rx-take.hpp:58
↓ 103 callers
Method
schedule_absolute
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:424
↓ 99 callers
Method
get
Rx/v2/src/rxcpp/subjects/rx-behavior.hpp:37
↓ 97 callers
Method
as_blocking
Rx/v2/src/rxcpp/rx-observable.hpp:591
↓ 94 callers
Method
count
Rx/v2/src/rxcpp/rx-observable.hpp:1253
↓ 79 callers
Method
add
Rx/v2/src/rxcpp/subjects/rx-subject.hpp:132
↓ 75 callers
Function
trace_activity
create a typedef for rxcpp_trace_type to override the default
Rx/v2/src/rxcpp/rx-predef.hpp:16
↓ 74 callers
Function
identity_current_thread
Rx/v2/src/rxcpp/rx-coordination.hpp:175
↓ 71 callers
Method
schedule
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:77
↓ 71 callers
Function
timer
Rx/v2/src/rxcpp/sources/rx-timer.hpp:114
↓ 67 callers
Method
unsubscribe
Rx/v2/src/rxcpp/rx-scheduler.hpp:246
↓ 65 callers
Method
connect
Rx/v2/src/rxcpp/rx-trace.hpp:66
↓ 65 callers
Method
unsubscribe
Rx/v2/test/subjects/subject.cpp:49
↓ 53 callers
Function
as_dynamic
Rx/v2/src/rxcpp/rx-subscriber.hpp:169
↓ 53 callers
Method
is_subscribed
composite_subscription
Rx/v2/src/rxcpp/rx-scheduler.hpp:234
↓ 51 callers
Method
end
Rx/v2/src/rxcpp/rx-util.hpp:631
↓ 50 callers
Function
from
Rx/v2/src/rxcpp/sources/rx-iterate.hpp:185
↓ 49 callers
Method
get_subscription
Rx/v2/src/rxcpp/subjects/rx-subject.hpp:257
↓ 48 callers
Method
act
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:297
↓ 47 callers
Method
get
Rx/v2/src/rxcpp/rx-util.hpp:792
↓ 46 callers
Function
from
Ix/CPP/src/cpplinq/linq.hpp:556
↓ 44 callers
Method
subscribe
Rx/v2/src/rxcpp/operators/rx-ref_count.hpp:63
↓ 43 callers
Method
begin
Rx/v2/src/rxcpp/rx-util.hpp:624
↓ 43 callers
Function
observe_on_new_thread
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:328
↓ 43 callers
Method
what
Rx/v2/src/rxcpp/rx-util.hpp:865
↓ 38 callers
Method
merge
Rx/v2/src/rxcpp/rx-observable.hpp:997
↓ 37 callers
Method
concat
Rx/v2/src/rxcpp/rx-observable.hpp:1052
↓ 35 callers
Method
reset
Rx/v2/src/rxcpp/subjects/rx-behavior.hpp:33
↓ 34 callers
Function
end
Rx/v2/src/rxcpp/rx-coroutine.hpp:189
↓ 33 callers
Method
on_completed
Rx/v2/src/rxcpp/operators/rx-all.hpp:89
↓ 32 callers
Function
begin
Rx/v2/src/rxcpp/rx-coroutine.hpp:183
↓ 32 callers
Method
combine_latest
Rx/v2/src/rxcpp/rx-observable.hpp:1097
↓ 32 callers
Method
zip
Rx/v2/src/rxcpp/operators/rx-zip.hpp:164
↓ 31 callers
Method
empty
Ix/CPP/src/cpplinq/linq.hpp:355
↓ 31 callers
Method
on_error
Rx/v2/src/rxcpp/operators/rx-all.hpp:86
↓ 31 callers
Method
with_latest_from
Rx/v2/src/rxcpp/rx-observable.hpp:1085
↓ 30 callers
Method
now
worker_interface return the current time for this worker
Rx/v2/src/rxcpp/rx-scheduler.hpp:253
↓ 29 callers
Function
rethrow_exception
Replace std::rethrow_exception to be compatible with our error_ptr typedef.
Rx/v2/src/rxcpp/rx-util.hpp:913
↓ 28 callers
Method
get_subscriber
Rx/v2/src/rxcpp/subjects/rx-subject.hpp:261
↓ 27 callers
Method
get
Ix/CPP/src/cpplinq/util.hpp:187
↓ 27 callers
Method
schedule
Rx/v2/src/rxcpp/rx-scheduler.hpp:801
↓ 25 callers
Method
in
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:287
↓ 25 callers
Method
on_next
Rx/v2/src/rxcpp/operators/rx-all.hpp:73
↓ 24 callers
Method
create_coordinator
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:313
↓ 24 callers
Method
is_subscribed
Rx/v2/test/subjects/subject.cpp:48
↓ 23 callers
Method
amb
Rx/v2/src/rxcpp/operators/rx-amb.hpp:90
↓ 23 callers
Method
out
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:292
↓ 22 callers
Method
clock
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:562
↓ 22 callers
Function
iterate
Rx/v2/src/rxcpp/sources/rx-iterate.hpp:160
↓ 21 callers
Method
get_observable
Rx/v2/src/rxcpp/subjects/rx-subject.hpp:265
↓ 20 callers
Method
inc
Ix/CPP/src/cpplinq/linq_cursor.hpp:157
↓ 19 callers
Function
current_exception
If called during exception handling, return the currently caught exception. Otherwise return null.
Rx/v2/src/rxcpp/rx-util.hpp:954
↓ 19 callers
Method
filter
Rx/v2/src/rxcpp/rx-observable.hpp:711
↓ 19 callers
Function
make_subscription
Rx/v2/src/rxcpp/rx-subscription.hpp:219
↓ 19 callers
Function
observe_on_event_loop
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:323
↓ 19 callers
Method
take_until
Rx/v2/src/rxcpp/rx-observable.hpp:1401
↓ 19 callers
Function
throw_exception
Rx/v2/src/rxcpp/rx-util.hpp:931
↓ 18 callers
Function
just
Rx/v2/src/rxcpp/sources/rx-iterate.hpp:267
↓ 18 callers
Method
now
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:309
↓ 18 callers
Method
on_next
Rx/v2/test/subjects/subject.cpp:50
↓ 18 callers
Method
remove
Rx/v2/src/rxcpp/rx-scheduler.hpp:240
↓ 17 callers
Method
lock
Rx/v2/src/rxcpp/rx-scheduler.hpp:348
↓ 17 callers
Method
name
Ix/CPP/unittest/testbench.hpp:13
↓ 17 callers
Method
publish
Rx/v2/src/rxcpp/rx-observable.hpp:1152
↓ 17 callers
Method
sequence_equal
Rx/v2/src/rxcpp/rx-observable.hpp:744
↓ 17 callers
Function
what
Rx/v2/src/rxcpp/rx-util.hpp:555
↓ 16 callers
Method
add
Rx/v2/src/rxcpp/rx-scheduler.hpp:237
↓ 16 callers
Method
on_completed
Rx/v2/test/operators/lift.cpp:47
↓ 15 callers
Method
buffer_with_time
Rx/v2/src/rxcpp/rx-observable.hpp:964
↓ 15 callers
Method
distinct
Rx/v2/src/rxcpp/rx-observable.hpp:876
↓ 15 callers
Method
str
Ix/CPP/unittest/testbench.hpp:76
↓ 14 callers
Method
get_cursor
Ix/CPP/src/cpplinq/linq.hpp:542
↓ 14 callers
Function
make_schedulable
copy
Rx/v2/src/rxcpp/rx-scheduler.hpp:742
↓ 14 callers
Method
on_next
Rx/v2/src/rxcpp/rx-observer.hpp:241
↓ 14 callers
Method
replay
Rx/v2/src/rxcpp/rx-observable.hpp:1174
↓ 14 callers
Method
select
Ix/CPP/src/cpplinq/linq.hpp:244
↓ 14 callers
Method
size
Rx/v2/src/rxcpp/rx-util.hpp:620
↓ 14 callers
Method
skip
Rx/v2/src/rxcpp/operators/rx-skip.hpp:59
↓ 13 callers
Function
apply
Rx/v2/src/rxcpp/rx-util.hpp:210
↓ 13 callers
Function
empty
Rx/v2/src/rxcpp/sources/rx-empty.hpp:37
next →
1–100 of 1,624, ranked by callers