Home
last modified time | relevance | path

Searched refs:rxo (Results 1 – 25 of 112) sorted by relevance

12345

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-replay.hpp79 struct replay_invalid : public rxo::operator_base<replay_invalid_arguments<AN...>> {
105 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
117 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
130 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
143 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
157 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
171 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
186 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
201 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
217 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
Drx-publish.hpp54 struct publish_invalid : public rxo::operator_base<publish_invalid_arguments<AN...>> {
99 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
111 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
123 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
147 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
Drx-group_by.hpp45 struct group_by_invalid : public rxo::operator_base<group_by_invalid_arguments<AN...>> {
329 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
330 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
340 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
341 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
352 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
353 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
366 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
367 …class GroupBy = rxo::detail::group_by<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<KeySelec…
382 …class Traits = rxo::detail::group_by_traits<SourceValue, rxu::decay_t<Observable>, KeySelector, Ma…
[all …]
Drx-repeat.hpp40 struct repeat_invalid : public rxo::operator_base<repeat_invalid_arguments<AN...>> {
94 class Repeat = rxo::detail::repeat::infinite<SourceValue, rxu::decay_t<Observable>>,
105 …class Repeat = rxo::detail::repeat::finite<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Cou…
Drx-retry.hpp36 struct retry_invalid : public rxo::operator_base<retry_invalid_arguments<AN...>> {
91 class Retry = rxo::detail::retry::infinite<SourceValue, rxu::decay_t<Observable>>,
103 …class Retry = rxo::detail::retry::finite<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Count…
Drx-merge.hpp58 struct merge_invalid : public rxo::operator_base<merge_invalid_arguments<AN...>> {
230 … class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
243 …class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordination>…
257 …class Merge = typename rxu::defer_type<rxo::detail::merge, SourceValue, ObservableObservable, iden…
272 …class Merge = typename rxu::defer_type<rxo::detail::merge, SourceValue, ObservableObservable, rxu:…
Drx-take_until.hpp52 struct take_until_invalid : public rxo::operator_base<take_until_invalid_arguments<AN...>> {
227 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
244 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
255 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
267 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
Drx-skip_until.hpp42 struct skip_until_invalid : public rxo::operator_base<skip_until_invalid_arguments<AN...>> {
219 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
236 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
247 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
259 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
Drx-amb.hpp54 struct amb_invalid : public rxo::operator_base<amb_invalid_arguments<AN...>> {
238 class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
251 … class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordination>>,
265 …class Amb = typename rxu::defer_type<rxo::detail::amb, SourceValue, ObservableObservable, identity…
280 …class Amb = typename rxu::defer_type<rxo::detail::amb, SourceValue, ObservableObservable, rxu::dec…
Drx-concat.hpp56 struct concat_invalid : public rxo::operator_base<concat_invalid_arguments<AN...>> {
249 … class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
262 …class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Coordinatio…
276 …class Concat = typename rxu::defer_type<rxo::detail::concat, SourceValue, ObservableObservable, id…
291 …class Concat = typename rxu::defer_type<rxo::detail::concat, SourceValue, ObservableObservable, rx…
Drx-distinct_until_changed.hpp35 struct distinct_until_changed_invalid : public rxo::operator_base<distinct_until_changed_invalid_ar…
115 … class DistinctUntilChanged = rxo::detail::distinct_until_changed<SourceValue, rxu::equal_to<>>>
126 … class DistinctUntilChanged = rxo::detail::distinct_until_changed<SourceValue, BinaryPredicate>>
Drx-reduce.hpp61 struct reduce_invalid : public rxo::operator_base<reduce_invalid_arguments<AN...>> {
508 …class Reduce = rxo::detail::reduce<rxu::value_type_t<Observable>, rxu::decay_t<Observable>, rxu::d…
518 …class Reduce = rxo::detail::reduce<rxu::value_type_t<Observable>, rxu::decay_t<Observable>, rxu::d…
544 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<TakeOne>, rxu::decay_t<Accumulator>, rxu::…
569 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, rx…
594 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, rx…
619 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, rx…
644 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, rx…
669 …class Reduce = rxo::detail::reduce<SValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, rx…
Drx-time_interval.hpp36 struct time_interval_invalid : public rxo::operator_base<time_interval_invalid_arguments<AN...>> {
125 class TimeInterval = rxo::detail::time_interval<SourceValue, identity_one_worker>,
137 class TimeInterval = rxo::detail::time_interval<SourceValue, rxu::decay_t<Coordination>>,
Drx-timestamp.hpp35 struct timestamp_invalid : public rxo::operator_base<timestamp_invalid_arguments<AN...>> {
119 class Timestamp = rxo::detail::timestamp<SourceValue, identity_one_worker>,
132 class Timestamp = rxo::detail::timestamp<SourceValue, rxu::decay_t<Coordination>>,
Drx-combine_latest.hpp53 struct combine_latest_invalid : public rxo::operator_base<combine_latest_invalid_arguments<AN...>> {
255 …class combine_latest = rxo::detail::combine_latest<identity_one_worker, rxu::detail::pack, rxu::de…
268 …class combine_latest = rxo::detail::combine_latest<identity_one_worker, ResolvedSelector, rxu::dec…
280 …class combine_latest = rxo::detail::combine_latest<Coordination, rxu::detail::pack, rxu::decay_t<O…
294 …class combine_latest = rxo::detail::combine_latest<Coordination, ResolvedSelector, rxu::decay_t<Ob…
Drx-with_latest_from.hpp53 struct with_latest_from_invalid : public rxo::operator_base<with_latest_from_invalid_arguments<AN..…
255 …class with_latest_from = rxo::detail::with_latest_from<identity_one_worker, rxu::detail::pack, rxu…
268 …class with_latest_from = rxo::detail::with_latest_from<identity_one_worker, ResolvedSelector, rxu:…
280 …class with_latest_from = rxo::detail::with_latest_from<Coordination, rxu::detail::pack, rxu::decay…
294 …class with_latest_from = rxo::detail::with_latest_from<Coordination, ResolvedSelector, rxu::decay_…
Drx-sequence_equal.hpp39 struct sequence_equal_invalid : public rxo::operator_base<sequence_equal_invalid_arguments<AN...>> {
225 …class SequenceEqual = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::deca…
239 …class SequenceEqual = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::deca…
252 …class SequenceEqual = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::deca…
265 …class SequenceEqual = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::deca…
Drx-buffer_count.hpp40 struct buffer_count_invalid : public rxo::operator_base<buffer_count_invalid_arguments<AN...>> {
150 class BufferCount = rxo::detail::buffer_count<SourceValue>,
161 class BufferCount = rxo::detail::buffer_count<SourceValue>,
Drx-window.hpp40 struct window_invalid : public rxo::operator_base<window_invalid_arguments<AN...>> {
152 class Window = rxo::detail::window<SourceValue>,
163 class Window = rxo::detail::window<SourceValue>,
Drx-switch_if_empty.hpp35 struct switch_if_empty_invalid : public rxo::operator_base<switch_if_empty_invalid_arguments<AN...>…
140 class SwitchIfEmpty = rxo::detail::switch_if_empty<SourceValue, rxu::decay_t<BackupSource>>>
162 class DefaultIfEmpty = rxo::detail::switch_if_empty<SourceValue, BackupSource>>
Drx-all.hpp36 struct all_invalid : public rxo::operator_base<all_invalid_arguments<AN...>> {
142 class All = rxo::detail::all<SourceValue, rxu::decay_t<Predicate>>,
165 class IsEmpty = rxo::detail::all<SourceValue, rxu::decay_t<Predicate>>,
Drx-connect_forever.hpp28 struct connect_forever_invalid : public rxo::operator_base<connect_forever_invalid_arguments<AN...>…
72 …class ConnectForever = rxo::detail::connect_forever<SourceValue, rxu::decay_t<ConnectableObservabl…
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dwindow_toggle.cpp44 | rxo::window_toggle(ys, [&](int y){ in __anon21f57c2a0102()
47 | rxo::map([wi](rxcpp::observable<int> w) mutable { in __anon21f57c2a0102()
50 … | rxo::map([ti](int x){return std::to_string(ti) + " " + std::to_string(x);}) in __anon21f57c2a0102()
52 | rxo::as_dynamic(); in __anon21f57c2a0102()
54 | rxo::merge() in __anon21f57c2a0102()
56 | rxo::as_dynamic(); in __anon21f57c2a0102()
Dobserve_on.cpp116 | rxo::observe_on(so); in __anondca263430502()
167 | rxo::observe_on(so) in __anondca263430602()
168 | rxo::map([](nocompare v){ return v.v; }) in __anondca263430602()
169 | rxo::as_dynamic(); in __anondca263430602()
Dretry.cpp36 | rxo::retry() in __anondb94a8670102()
38 | rxo::as_dynamic(); in __anondb94a8670102()
95 | rxo::retry(0) in __anondb94a8670202()
97 | rxo::as_dynamic(); in __anondb94a8670202()

12345