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
↓ 12 callers
Function
identity_immediate
Rx/v2/src/rxcpp/rx-coordination.hpp:170
↓ 12 callers
Method
merge_transform
Rx/v2/src/rxcpp/rx-observable.hpp:1041
↓ 12 callers
Method
op
Rx/v2/src/rxcpp/rx-observable.hpp:604
↓ 12 callers
Method
reset
Rx/v2/src/rxcpp/rx-util.hpp:665
↓ 12 callers
Method
sum
Rx/v2/src/rxcpp/rx-observable.hpp:1265
↓ 12 callers
Method
where
Ix/CPP/src/cpplinq/linq.hpp:262
↓ 12 callers
Method
window_with_time
Rx/v2/src/rxcpp/rx-observable.hpp:920
↓ 11 callers
Function
apply_to
Rx/v2/src/rxcpp/rx-util.hpp:273
↓ 11 callers
Method
concat_transform
Rx/v2/src/rxcpp/rx-observable.hpp:1074
↓ 11 callers
Method
get_worker
Rx/v2/src/rxcpp/operators/rx-observe_on.hpp:277
↓ 11 callers
Method
last
Rx/v2/src/rxcpp/rx-observable.hpp:1241
↓ 11 callers
Method
skip_until
Rx/v2/src/rxcpp/rx-observable.hpp:1368
↓ 11 callers
Method
subscribe_on
Rx/v2/src/rxcpp/rx-observable.hpp:1185
↓ 10 callers
Method
buffer
Rx/v2/src/rxcpp/rx-observable.hpp:953
↓ 10 callers
Function
max
! \brief For each item from this observable reduce it by taking the max value of the previous items. \return An observable that emits a single i
Rx/v2/src/rxcpp/operators/rx-reduce.hpp:496
↓ 10 callers
Method
max
Rx/v2/src/rxcpp/rx-observable.hpp:1289
↓ 10 callers
Method
min
Rx/v2/src/rxcpp/rx-observable.hpp:1301
↓ 10 callers
Method
observe_on
Rx/v2/src/rxcpp/rx-observable.hpp:1196
↓ 9 callers
Function
accumulate
Rx/v2/src/rxcpp/operators/rx-reduce.hpp:361
↓ 9 callers
Method
add
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:41
↓ 9 callers
Method
distinct_until_changed
Rx/v2/src/rxcpp/rx-observable.hpp:887
↓ 9 callers
Method
finally
Rx/v2/src/rxcpp/rx-observable.hpp:799
↓ 9 callers
Method
get_worker
Rx/v2/src/rxcpp/rx-scheduler.hpp:551
↓ 9 callers
Function
make_error_ptr
TODO: Do we really need an identity make? (It was causing some compilation errors deep inside templates).
Rx/v2/src/rxcpp/rx-util.hpp:894
↓ 9 callers
Method
on_error
Rx/v2/test/operators/lift.cpp:17
↓ 9 callers
Method
ref_count
Rx/v2/src/rxcpp/rx-observable.hpp:580
↓ 9 callers
Method
repeat
Rx/v2/src/rxcpp/rx-observable.hpp:1423
↓ 9 callers
Method
take_while
Rx/v2/src/rxcpp/rx-observable.hpp:1412
↓ 8 callers
Method
average
Rx/v2/src/rxcpp/rx-observable.hpp:1277
↓ 8 callers
Method
begin
Ix/CPP/unittest/testbench.cpp:88
↓ 8 callers
Method
count
Ix/CPP/src/cpplinq/linq.hpp:320
↓ 8 callers
Method
create_coordinator
Rx/v2/src/rxcpp/rx-coordination.hpp:164
↓ 8 callers
Function
on_error
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:154
↓ 8 callers
Method
on_error
Rx/v2/src/rxcpp/rx-observer.hpp:247
↓ 8 callers
Method
skip_while
Rx/v2/src/rxcpp/rx-observable.hpp:1346
↓ 8 callers
Method
sum
Ix/CPP/src/cpplinq/linq.hpp:475
↓ 8 callers
Function
synchronize_event_loop
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:251
↓ 8 callers
Method
transform
Rx/v2/src/rxcpp/rx-observable.hpp:843
↓ 7 callers
Method
accept
Rx/v2/src/rxcpp/rx-notification.hpp:142
↓ 7 callers
Method
create_coordinator
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:245
↓ 7 callers
Function
delay
Rx/v2/src/rxcpp/operators/rx-delay.hpp:182
↓ 7 callers
Method
element_at
Rx/v2/src/rxcpp/rx-observable.hpp:898
↓ 7 callers
Method
get_worker
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:209
↓ 7 callers
Function
is_subscribed
composite_subscription
Rx/v2/src/rxcpp/rx-subscriber.hpp:200
↓ 7 callers
Function
map
Rx/v2/src/rxcpp/operators/rx-map.hpp:105
↓ 7 callers
Method
pop
Rx/v2/src/rxcpp/schedulers/rx-virtualtime.hpp:196
↓ 7 callers
Method
scan
Rx/v2/src/rxcpp/operators/rx-scan.hpp:64
↓ 7 callers
Method
start_with
Rx/v2/src/rxcpp/rx-observable.hpp:1445
↓ 7 callers
Method
unsubscribe
Rx/v2/src/rxcpp/rx-subscription.hpp:602
↓ 6 callers
Method
act
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:229
↓ 6 callers
Method
buffer_with_time_or_count
Rx/v2/src/rxcpp/rx-observable.hpp:975
↓ 6 callers
Method
end
Ix/CPP/unittest/testbench.cpp:89
↓ 6 callers
Method
handled
Rx/v2/examples/win_text/rx_windows_user.h:24
↓ 6 callers
Method
insert
Ix/CPP/src/cpplinq/linq_groupby.hpp:108
↓ 6 callers
Function
make_same_worker
Rx/v2/src/rxcpp/schedulers/rx-sameworker.hpp:44
↓ 6 callers
Function
on_next
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:151
↓ 6 callers
Method
on_next
Rx/v2/src/rxcpp/subjects/rx-behavior.hpp:61
↓ 6 callers
Function
pack
Rx/v2/src/rxcpp/rx-util.hpp:296
↓ 6 callers
Method
publish_synchronized
Rx/v2/src/rxcpp/rx-observable.hpp:1163
↓ 6 callers
Method
skip_last
Rx/v2/src/rxcpp/rx-observable.hpp:1357
↓ 6 callers
Method
switch_on_next
Rx/v2/src/rxcpp/rx-observable.hpp:986
↓ 6 callers
Function
take
Rx/v2/src/rxcpp/operators/rx-take.hpp:133
↓ 6 callers
Method
take_last
Rx/v2/src/rxcpp/rx-observable.hpp:1390
↓ 6 callers
Method
tap
Rx/v2/src/rxcpp/operators/rx-tap.hpp:69
↓ 6 callers
Method
window_with_time_or_count
Rx/v2/src/rxcpp/rx-observable.hpp:931
↓ 5 callers
Function
IsPrime
Rx/v2/test/operators/filter.cpp:5
↓ 5 callers
Function
add
Rx/v2/src/rxcpp/rx-subscriber.hpp:203
↓ 5 callers
Method
advance_to
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:450
↓ 5 callers
Method
all
Rx/v2/src/rxcpp/operators/rx-all.hpp:51
↓ 5 callers
Method
any
Rx/v2/src/rxcpp/operators/rx-any.hpp:58
↓ 5 callers
Method
contains
Rx/v2/src/rxcpp/rx-observable.hpp:700
↓ 5 callers
Method
debounce
Rx/v2/src/rxcpp/rx-observable.hpp:854
↓ 5 callers
Method
delay
Rx/v2/src/rxcpp/rx-observable.hpp:865
↓ 5 callers
Method
exists
Rx/v2/src/rxcpp/rx-observable.hpp:689
↓ 5 callers
Method
first
Rx/v2/src/rxcpp/rx-observable.hpp:1229
↓ 5 callers
Method
flat_map
Rx/v2/src/rxcpp/rx-observable.hpp:1030
↓ 5 callers
Method
get
Ix/CPP/src/cpplinq/linq_selectmany.hpp:131
↓ 5 callers
Function
get_id
Rx/v2/src/rxcpp/rx-subscriber.hpp:165
↓ 5 callers
Method
get_id
Rx/v2/src/rxcpp/subjects/rx-subject.hpp:118
↓ 5 callers
Method
group_by
Rx/v2/src/rxcpp/rx-observable.hpp:1119
↓ 5 callers
Function
make_action
Rx/v2/src/rxcpp/rx-scheduler.hpp:735
↓ 5 callers
Function
make_new_thread
Rx/v2/src/rxcpp/schedulers/rx-newthread.hpp:170
↓ 5 callers
Function
member
Rx/v2/src/rxcpp/operators/rx-scan.hpp:117
↓ 5 callers
Function
merge
Rx/v2/src/rxcpp/operators/rx-merge.hpp:216
↓ 5 callers
Method
now
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:553
↓ 5 callers
Function
on_completed
Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp:157
↓ 5 callers
Method
on_completed
Rx/v2/src/rxcpp/rx-observer.hpp:250
↓ 5 callers
Method
on_subscribe
Rx/v2/src/rxcpp/rx-observable.hpp:564
↓ 5 callers
Method
push
Rx/v2/src/rxcpp/schedulers/rx-currentthread.hpp:80
↓ 5 callers
Method
reduce
Rx/v2/src/rxcpp/rx-observable.hpp:1207
↓ 5 callers
Method
schedule_periodically
Rx/v2/src/rxcpp/rx-scheduler.hpp:839
↓ 5 callers
Method
skip
Ix/CPP/src/cpplinq/linq.hpp:468
↓ 5 callers
Function
start_with
Rx/v2/src/rxcpp/sources/rx-iterate.hpp:316
↓ 5 callers
Method
subscribe
Rx/v2/src/rxcpp/schedulers/rx-test.hpp:402
↓ 5 callers
Method
switch_if_empty
Rx/v2/src/rxcpp/rx-observable.hpp:722
↓ 5 callers
Method
time
Rx/v2/src/rxcpp/rx-notification.hpp:249
↓ 5 callers
Method
timeout
Rx/v2/src/rxcpp/rx-observable.hpp:777
↓ 5 callers
Method
value
Rx/v2/src/rxcpp/rx-operators.hpp:57
↓ 5 callers
Method
window
Rx/v2/src/rxcpp/rx-observable.hpp:909
↓ 5 callers
Method
window_toggle
Rx/v2/src/rxcpp/rx-observable.hpp:942
← previous
next →
101–200 of 1,624, ranked by callers