Home
last modified time | relevance | path

Searched refs:rxu (Results 1 – 25 of 166) sorted by relevance

1234567

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-group_by.hpp54 typedef rxu::decay_t<Selector> selector_type;
71 typedef rxu::decay_t<Observable> source_type;
72 typedef rxu::decay_t<KeySelector> key_selector_type;
73 typedef rxu::decay_t<MarbleSelector> marble_selector_type;
74 typedef rxu::decay_t<BinaryPredicate> predicate_type;
75 typedef rxu::decay_t<DurationSelector> duration_selector_type;
185 typedef rxu::decay_t<Subscriber> dest_type;
203 [this](rxu::error_ptr e){on_error(e);}); in on_next()
218 [this](rxu::error_ptr e){on_error(e);}); in on_next()
240 [=](rxu::error_ptr) {expire();}, in on_next()
[all …]
Drx-reduce.hpp70 typedef rxu::decay_t<ResultSelector> result_selector_type;
71 typedef rxu::decay_t<Seed> seed_type;
80 typedef rxu::decay_t<decltype(check<seed_type, result_selector_type>(0))> type;
87 typedef rxu::decay_t<Observable> source_type;
88 typedef rxu::decay_t<Accumulator> accumulator_type;
89 typedef rxu::decay_t<ResultSelector> result_selector_type;
90 typedef rxu::decay_t<Seed> seed_type;
98 struct reduce : public operator_base<rxu::value_type_t<reduce_traits<T, Observable, Accumulator, Re…
169 [state](rxu::error_ptr e) { in on_subscribe()
206 rxu::maybe<T> value;
[all …]
Drx-flat_map.hpp54 typedef rxu::decay_t<Observable> source_type;
55 typedef rxu::decay_t<CollectionSelector> collection_selector_type;
56 typedef rxu::decay_t<ResultSelector> result_selector_type;
57 typedef rxu::decay_t<Coordination> coordination_type;
69 …typedef rxu::decay_t<decltype((*(collection_selector_type*)nullptr)((*(source_value_type*)nullptr)…
82 …typedef rxu::decay_t<decltype((*(result_selector_type*)nullptr)(*(source_value_type*)nullptr, *(co…
87 …: public operator_base<rxu::value_type_t<flat_map_traits<Observable, CollectionSelector, ResultSel…
201 [state](rxu::error_ptr e) { in on_subscribe()
216 [state](rxu::error_ptr e) { in on_subscribe()
263 class CollectionSelectorType = rxu::decay_t<CollectionSelector>,
[all …]
Drx-concat_map.hpp54 typedef rxu::decay_t<Observable> source_type;
55 typedef rxu::decay_t<CollectionSelector> collection_selector_type;
56 typedef rxu::decay_t<ResultSelector> result_selector_type;
57 typedef rxu::decay_t<Coordination> coordination_type;
84 …typedef rxu::decay_t<decltype((*(result_selector_type*)nullptr)(*(source_value_type*)nullptr, *(co…
89 …: public operator_base<rxu::value_type_t<concat_traits<Observable, CollectionSelector, ResultSelec…
186 [state](rxu::error_ptr e) { in on_subscribe()
249 [state](rxu::error_ptr e) { in on_subscribe()
296 class CollectionSelectorType = rxu::decay_t<CollectionSelector>,
297 class SourceValue = rxu::value_type_t<Observable>,
[all …]
Drx-replay.hpp101 class Enabled = rxu::enable_if_all_true_type_t<
103 class SourceValue = rxu::value_type_t<Observable>,
105 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
113 class Enabled = rxu::enable_if_all_true_type_t<
115 class SourceValue = rxu::value_type_t<Observable>,
117 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
125 class Enabled = rxu::enable_if_all_true_type_t<
128 class SourceValue = rxu::value_type_t<Observable>,
129 class Subject = rxsub::replay<SourceValue, rxu::decay_t<Coordination>>,
130 class Multicast = rxo::detail::multicast<SourceValue, rxu::decay_t<Observable>, Subject>,
[all …]
Drx-sequence_equal.hpp48 typedef rxu::decay_t<Observable> source_type;
49 typedef rxu::decay_t<T> source_value_type;
50 typedef rxu::decay_t<OtherObservable> other_source_type;
52 typedef rxu::decay_t<BinaryPredicate> predicate_type;
53 typedef rxu::decay_t<Coordination> coordination_type;
164 [state](rxu::error_ptr e) { in on_subscribe()
192 [state](rxu::error_ptr e) { in on_subscribe()
221 class Enabled = rxu::enable_if_all_true_type_t<
224 class SourceValue = rxu::value_type_t<Observable>,
225 …al = rxo::detail::sequence_equal<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<OtherObservab…
[all …]
Drx-zip.hpp52 using value_type = rxu::value_type_t<Observable>;
76 template<class Observable, class Value = rxu::value_type_t<Observable>>
96 typedef rxu::decay_t<Selector> selector_type;
104 using type = decltype(check<selector_type, rxu::decay_t<ObservableN>...>(0));
126 typedef std::tuple<rxu::decay_t<ObservableN>...> tuple_source_type;
129 typedef rxu::decay_t<Selector> selector_type;
130 typedef rxu::decay_t<Coordination> coordination_type;
136 struct zip : public operator_base<rxu::value_type_t<zip_traits<Coordination, Selector, ObservableN.…
197 … if (rxu::apply_to_each(state->pending, values_not_empty(), rxu::all_values_true())) { in subscribe_one()
198 … auto selectedResult = rxu::apply_to_each(state->pending, extract_value_front(), state->selector); in subscribe_one()
[all …]
Drx-combine_latest.hpp61 typedef rxu::decay_t<Selector> selector_type;
69 using type = decltype(check<selector_type, rxu::decay_t<ObservableN>...>(0));
93 …typedef std::tuple<rxu::detail::maybe<typename ObservableN::value_type>...> tuple_source_value_typ…
95 typedef rxu::decay_t<Selector> selector_type;
96 typedef rxu::decay_t<Coordination> coordination_type;
102 struct combine_latest : public operator_base<rxu::value_type_t<combine_latest_traits<Coordination, …
170 auto values = rxu::surely(state->latest); in subscribe_one()
171 auto selectedResult = rxu::apply(values, state->selector); in subscribe_one()
176 [state](rxu::error_ptr e) { in subscribe_one()
195 void subscribe_all(std::shared_ptr<State> state, rxu::values<int, IndexN...>) const { in subscribe_all()
[all …]
Drx-with_latest_from.hpp61 typedef rxu::decay_t<Selector> selector_type;
69 using type = decltype(check<selector_type, rxu::decay_t<ObservableN>...>(0));
93 …typedef std::tuple<rxu::detail::maybe<typename ObservableN::value_type>...> tuple_source_value_typ…
95 typedef rxu::decay_t<Selector> selector_type;
96 typedef rxu::decay_t<Coordination> coordination_type;
102 struct with_latest_from : public operator_base<rxu::value_type_t<with_latest_from_traits<Coordinati…
170 auto values = rxu::surely(state->latest); in subscribe_one()
171 auto selectedResult = rxu::apply(values, state->selector); in subscribe_one()
176 [state](rxu::error_ptr e) { in subscribe_one()
195 void subscribe_all(std::shared_ptr<State> state, rxu::values<int, IndexN...>) const { in subscribe_all()
[all …]
Drx-take_until.hpp61 typedef rxu::decay_t<Observable> source_type;
62 typedef rxu::decay_t<TriggerObservable> trigger_source_type;
63 typedef rxu::decay_t<Coordination> coordination_type;
150 [state](rxu::error_ptr e) { in on_subscribe()
182 [state](rxu::error_ptr e) { in on_subscribe()
220 class Enabled = rxu::enable_if_all_true_type_t<
223 class SourceValue = rxu::value_type_t<Observable>,
224 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
225 class TimerValue = rxu::value_type_t<Timer>,
227 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
[all …]
Drx-skip_until.hpp51 typedef rxu::decay_t<Observable> source_type;
52 typedef rxu::decay_t<TriggerObservable> trigger_source_type;
53 typedef rxu::decay_t<Coordination> coordination_type;
142 [state](rxu::error_ptr e) { in on_subscribe()
177 [state](rxu::error_ptr e) { in on_subscribe()
212 class Enabled = rxu::enable_if_all_true_type_t<
215 class SourceValue = rxu::value_type_t<Observable>,
216 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
217 class TimerValue = rxu::value_type_t<Timer>,
219 …class SkipUntil = rxo::detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable…
[all …]
Drx-merge_delay_error.hpp59 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
66 typedef rxu::decay_t<T> source_value_type;
67 typedef rxu::decay_t<Observable> source_type;
72 typedef rxu::decay_t<Coordination> coordination_type;
170 [state](rxu::error_ptr e) { in on_subscribe()
173 … rxu::make_error_ptr(std::move(state->exception.add(e)))); in on_subscribe()
183 … rxu::make_error_ptr(std::move(state->exception))); in on_subscribe()
195 [state](rxu::error_ptr e) { in on_subscribe()
198 rxu::make_error_ptr(std::move(state->exception.add(e)))); in on_subscribe()
208 rxu::make_error_ptr(std::move(state->exception))); in on_subscribe()
[all …]
Drx-merge.hpp66 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
73 typedef rxu::decay_t<T> source_value_type;
74 typedef rxu::decay_t<Observable> source_type;
79 typedef rxu::decay_t<Coordination> coordination_type;
176 [state](rxu::error_ptr e) { in on_subscribe()
191 [state](rxu::error_ptr e) { in on_subscribe()
227 class Enabled = rxu::enable_if_all_true_type_t<
229 class SourceValue = rxu::value_type_t<Observable>,
230 … class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
231 class Value = rxu::value_type_t<SourceValue>,
[all …]
Drx-concat.hpp64 : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
68 typedef rxu::decay_t<T> source_value_type;
69 typedef rxu::decay_t<Observable> source_type;
70 typedef rxu::decay_t<Coordination> coordination_type;
146 [state](rxu::error_ptr e) { in on_subscribe()
210 [state](rxu::error_ptr e) { in on_subscribe()
246 class Enabled = rxu::enable_if_all_true_type_t<
248 class SourceValue = rxu::value_type_t<Observable>,
249 … class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
250 class Value = rxu::value_type_t<SourceValue>,
[all …]
Drx-amb.hpp62 : public operator_base<rxu::value_type_t<T>>
69 typedef rxu::decay_t<T> source_value_type;
70 typedef rxu::decay_t<Observable> source_type;
75 typedef rxu::decay_t<Coordination> coordination_type;
186 [state](rxu::error_ptr e) { in on_subscribe()
199 [state](rxu::error_ptr e) { in on_subscribe()
235 class Enabled = rxu::enable_if_all_true_type_t<
237 class SourceValue = rxu::value_type_t<Observable>,
238 class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
239 class Value = rxu::value_type_t<SourceValue>,
[all …]
Drx-scan.hpp44 struct scan : public operator_base<rxu::decay_t<Seed>>
46 typedef rxu::decay_t<Observable> source_type;
47 typedef rxu::decay_t<Accumulator> accumulator_type;
48 typedef rxu::decay_t<Seed> seed_type;
93 [state](rxu::error_ptr e) { in on_subscribe()
120 class Enabled = rxu::enable_if_all_true_type_t<
122 …is_accumulate_function_for<rxu::value_type_t<Observable>, rxu::decay_t<Seed>, rxu::decay_t<Accumul…
123 class SourceValue = rxu::value_type_t<Observable>,
124 …class Scan = rxo::detail::scan<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Accumulator>, r…
125 class Value = rxu::value_type_t<Scan>,
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dbuffer.cpp36 auto required = rxu::to_vector({
37 v_on.next(250, rxu::to_vector({ 2, 3, 4, 5 })),
45 auto required = rxu::to_vector({
83 auto required = rxu::to_vector({
84 v_on.next(220, rxu::to_vector({ 2, 3 })),
85 v_on.next(240, rxu::to_vector({ 4, 5 })),
93 auto required = rxu::to_vector({
131 auto required = rxu::to_vector({
132 v_on.next(230, rxu::to_vector({ 2, 3, 4 })),
133 v_on.next(250, rxu::to_vector({ 5 })),
[all …]
Dzip.cpp41 auto required = rxu::to_vector({
49 auto required = rxu::to_vector({
101 auto required = rxu::to_vector({ in __anon117b13840502()
150 auto required = rxu::to_vector({
158 auto required = rxu::to_vector({
206 auto required = rxu::to_vector({
214 auto required = rxu::to_vector({
257 auto required = rxu::to_vector({
265 auto required = rxu::to_vector({
273 auto required = rxu::to_vector({
[all …]
Damb.cpp48 auto required = rxu::to_vector({
56 auto required = rxu::to_vector({
64 auto required = rxu::to_vector({
72 auto required = rxu::to_vector({
116 auto required = rxu::to_vector({
124 auto required = rxu::to_vector({
132 auto required = rxu::to_vector({
140 auto required = rxu::to_vector({
197 auto required = rxu::to_vector({
208 auto required = rxu::to_vector({
[all …]
Dcombine_latest.cpp43 auto required = rxu::to_vector({
56 auto required = rxu::to_vector({
64 auto required = rxu::to_vector({
111 auto required = rxu::to_vector({
121 auto required = rxu::to_vector({
129 auto required = rxu::to_vector({
178 auto required = rxu::to_vector({
186 auto required = rxu::to_vector({
194 auto required = rxu::to_vector({
243 auto required = rxu::to_vector({
[all …]
Dwith_latest_from.cpp43 auto required = rxu::to_vector({
55 auto required = rxu::to_vector({
63 auto required = rxu::to_vector({
110 auto required = rxu::to_vector({
120 auto required = rxu::to_vector({
128 auto required = rxu::to_vector({
177 auto required = rxu::to_vector({
185 auto required = rxu::to_vector({
193 auto required = rxu::to_vector({
242 auto required = rxu::to_vector({
[all …]
Damb_variadic.cpp40 auto required = rxu::to_vector({
48 auto required = rxu::to_vector({
56 auto required = rxu::to_vector({
93 auto required = rxu::to_vector({
101 auto required = rxu::to_vector({
109 auto required = rxu::to_vector({
146 auto required = rxu::to_vector({
154 auto required = rxu::to_vector({
162 auto required = rxu::to_vector({
211 auto required = rxu::to_vector({
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-predef.hpp22 template<class T, class C = rxu::types_checked>
26 struct is_action<T, typename rxu::types_checked_from<typename T::action_tag>::type>
40 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_worker*>::v…
53 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_scheduler*>…
66 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_schedulable…
97 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_observer*>:…
110 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_dynamic_obs…
123 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_subscriber*…
136 …static const bool value = std::is_convertible<decltype(check<rxu::decay_t<T>>(0)), tag_dynamic_obs…
163 template<class T, class =rxu::types_checked>
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
Drx-error.hpp43 typedef rxu::decay_t<Coordination> coordination_type;
49 error_initial_type(rxu::error_ptr e, coordination_type cn) in error_initial_type()
54 rxu::error_ptr exception;
59 error(rxu::error_ptr e, coordination_type cn) in error()
96 auto make_error(throw_ptr_tag&&, rxu::error_ptr exception, Coordination cn) in make_error()
104 rxu::error_ptr ep = rxu::make_error_ptr(e); in make_error()
118 …-> decltype(detail::make_error<T>(typename std::conditional<std::is_same<rxu::error_ptr, rxu::deca… in error()
119 …return detail::make_error<T>(typename std::conditional<std::is_same<rxu::error_ptr, rxu::deca… in error()
125 …-> decltype(detail::make_error<T>(typename std::conditional<std::is_same<rxu::error_ptr, rxu::deca… in error()
126 …return detail::make_error<T>(typename std::conditional<std::is_same<rxu::error_ptr, rxu::deca… in error()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dscope.cpp9 rxu::detail::maybe<rx::test::testable_observable<int>> xs;
20 return resource(rxu::to_vector({1, 2, 3, 4, 5})); in __anon0a7a75b00102()
41 auto required = rxu::to_vector({
54 auto required = rxu::to_vector({
70 rxu::detail::maybe<rx::test::testable_observable<int>> xs;
81 return resource(rxu::to_vector({1, 2, 3, 4, 5})); in __anon0a7a75b00502()
102 auto required = rxu::to_vector({
115 auto required = rxu::to_vector({
134 rxu::detail::maybe<rx::test::testable_observable<int>> xs;
150 xs.reset(sc.make_cold_observable(rxu::to_vector({ in __anon0a7a75b00902()
[all …]

1234567