| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 37 : public rxs::source_base<T>
52 void construct(SO&& source, rxs::tag_source&&) { in construct()
78 …typename std::conditional<rxs::is_source<SOF>::value || rxo::is_operator<SOF>::value, rxs::tag_sou… in dynamic_observable()
536 …static_assert(rxo::is_operator<source_operator_type>::value || rxs::is_source<source_operator_type…
644 decltype(rxs::from<ResultType>())>::type { in lift_if()
645 return rxs::from<ResultType>(); in lift_if()
1569 -> decltype(rxs::create<T>(std::move(os))) { in create()
1570 return rxs::create<T>(std::move(os)); in create()
1577 -> decltype(rxs::range<T>(first, last, step, identity_current_thread())) { in range()
1578 return rxs::range<T>(first, last, step, identity_current_thread()); in range()
[all …]
|
| D | rx-sources.hpp | 34 namespace rxs=sources;
|
| D | rx-connectable_observable.hpp | 53 void construct(SO&& source, rxs::tag_source&&) { in construct()
74 …td::conditional<is_dynamic_observable<SOF>::value, tag_dynamic_observable, rxs::tag_source>::type(… in dynamic_connectable_observable()
|
| D | rx-grouped_observable.hpp | 61 void construct(SO&& source, const rxs::tag_source&) { in construct()
80 …is_dynamic_grouped_observable<SOF>::value, tag_dynamic_grouped_observable, rxs::tag_source>::type(… in dynamic_grouped_observable()
|
| D | rx-test.hpp | 29 : public rxs::source_base<T>
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | concat.cpp | 20 auto c = rxs::range(0, sectionCount - 1, 1, so)
23 rxs::range(sectionCount, sectionCount * 2 - 1, 1, so),
24 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
48 int c = rxs::range(0, sectionCount - 1, 1, so)
51 rxs::range(sectionCount, sectionCount * 2 - 1, 1, so),
52 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
76 int c = rxs::range(0, sectionCount - 1, 1, so)
79 rxs::range(sectionCount, sectionCount * 2 - 1, 1, so),
80 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
|
| D | merge.cpp | 21 int c = rxs::range(0, sectionCount - 1, 1, so)
24 rxs::range(sectionCount, (sectionCount * 2) - 1, 1, so),
25 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
49 int c = rxs::range(0, sectionCount - 1, 1, so)
52 rxs::range(sectionCount, (sectionCount * 2) - 1, 1, so),
53 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
77 int c = rxs::range(0, sectionCount - 1, 1, so)
80 rxs::range(sectionCount, (sectionCount * 2) - 1, 1, so),
81 rxs::range(sectionCount * 2, onnextcalls - 1, 1, so))
|
| D | concat_map.cpp | 27 rxs::range(1, so)
30 return rxs::range(1, z, 1, so) in __anon7becb6260102()
33 return rxs::range(x, z, 1, so) in __anon7becb6260102()
69 rxs::range(1, so)
72 return rxs::range(1, z, 1, so) in __anon7becb6260902()
75 return rxs::range(x, z, 1, so) in __anon7becb6260902()
117 rxs::range(1, so)
120 return rxs::range(1, z, 1, so) in __anon7becb6260f02()
123 return rxs::range(x, z, 1, so) in __anon7becb6260f02()
166 rxs::range(1, so)
[all …]
|
| D | flat_map.cpp | 62 rxs::range(1, so)
65 return rxs::range(1, z, 1, so) in __anon63d55a350102()
68 return rxs::range(x, z, 1, so) in __anon63d55a350102()
105 rxs::range(1, so)
108 return rxs::range(1, z, 1, so) in __anon63d55a350802()
111 return rxs::range(x, z, 1, so) in __anon63d55a350802()
153 rxs::range(1, so)
156 return rxs::range(1, z, 1, so) in __anon63d55a350e02()
159 return rxs::range(x, z, 1, so) in __anon63d55a350e02()
201 rxs::range(1, so)
[all …]
|
| D | publish.cpp | 12 auto published = rxs::range<int>(0, 10).publish();
23 auto published = rxs::range<int>(0, 10).publish().ref_count();
32 auto published = rxs::range<int>(0, 10).publish().connect_forever();
46 auto published = rxs::range<int>(0, 3).publish().ref_count();
66 auto published = rxs::range<double>(0, 10).publish();
90 auto source = rxs::range<double>(0, 3);
|
| D | observe_on.cpp | 30 rxs::range<int>(1)
|
| /external/rust/crates/futures-util/benches/ |
| D | futures_unordered.rs | 20 let mut rxs = FuturesUnordered::new(); in oneshots() localVariable
25 rxs.push(rx); in oneshots()
36 if let Poll::Ready(None) = rxs.poll_next_unpin(cx) { in oneshots()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-group_by.hpp | 156 struct group_by_observable : public rxs::source_base<marble_type>
338 class DurationSelector=rxu::ret<observable<int, rxs::detail::never<int>>>,
344 …eSelector>(ms), std::forward<BinaryPredicate>(p), rxu::ret<observable<int, rxs::detail::never<int>… in member()
345 …eSelector>(ms), std::forward<BinaryPredicate>(p), rxu::ret<observable<int, rxs::detail::never<int>… in member()
350 class DurationSelector=rxu::ret<observable<int, rxs::detail::never<int>>>,
356 …), std::forward<MarbleSelector>(ms), rxu::less(), rxu::ret<observable<int, rxs::detail::never<int>… in member()
357 …), std::forward<MarbleSelector>(ms), rxu::less(), rxu::ret<observable<int, rxs::detail::never<int>… in member()
364 class DurationSelector=rxu::ret<observable<int, rxs::detail::never<int>>>,
370 …tor>(ks), rxu::detail::take_at<0>(), rxu::less(), rxu::ret<observable<int, rxs::detail::never<int>… in member()
371 …tor>(ks), rxu::detail::take_at<0>(), rxu::less(), rxu::ret<observable<int, rxs::detail::never<int>… in member()
[all …]
|
| D | rx-switch_if_empty.hpp | 161 class BackupSource = decltype(rxs::from(std::declval<SourceValue>())),
164 -> decltype(o.template lift<SourceValue>(DefaultIfEmpty(rxs::from(std::move(v))))) { in member()
165 return o.template lift<SourceValue>(DefaultIfEmpty(rxs::from(std::move(v)))); in member()
|
| D | rx-start_with.hpp | 66 …class From = decltype(rxs::from(rxu::decay_t<Value0>(std::declval<Value0>()), rxu::decay_t<ValueN>…
70 auto first = rxs::from(rxu::decay_t<Value0>(v0), rxu::decay_t<ValueN>(vn)...); in member()
|
| D | rx-take_until.hpp | 224 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
232 …return Result(TakeUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
241 … class Timer = typename rxu::defer_type<rxs::detail::timer, rxu::decay_t<Coordination>>::type,
248 …return Result(TakeUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
|
| D | rx-skip_until.hpp | 216 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
224 …return Result(SkipUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
233 … class Timer = typename rxu::defer_type<rxs::detail::timer, rxu::decay_t<Coordination>>::type,
240 …return Result(SkipUntil(std::forward<Observable>(o), rxs::timer(std::forward<TimePoint>(when), cn)… in member()
|
| D | rx-merge.hpp | 262 …return Result(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_curre… in member()
277 …return Result(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), std::forward<C… in member()
|
| D | rx-merge_delay_error.hpp | 276 …return Result(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_curre… in member()
291 …return Result(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), std::forward<C… in member()
|
| D | rx-amb.hpp | 270 …return Result(Amb(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_current… in member()
285 …return Result(Amb(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), std::forward<Coo… in member()
|
| D | rx-concat.hpp | 281 …return Result(Concat(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_curr… in member()
296 …return Result(Concat(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), std::forward<… in member()
|
| /external/ltp/testcases/network/can/filter-tests/ |
| D | can_rcv_own_msgs.c | 63 struct rxs { struct
68 struct rxs test_sockets(int s, int t, canid_t can_id) in test_sockets() argument
75 struct rxs rx; in test_sockets()
154 struct rxs rx; in main()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 158 auto s0 = rxs::range(1, es) in __anon442cb92f0a02()
173 auto s1 = rxs::range(values + 1, es) in __anon442cb92f0a02()
188 auto s2 = rxs::range((values * 2) + 1, es) in __anon442cb92f0a02()
267 auto s0 = rxs::range(1, es) in __anon442cb92f1602()
281 auto s1 = rxs::range(values + 1, es) in __anon442cb92f1602()
295 auto s2 = rxs::range((values * 2) + 1, es) in __anon442cb92f1602()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/ |
| D | test.h | 13 namespace rxs=rxcpp::sources; variable
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 286 rxs::range<int>(1, onnextcalls).subscribe(
425 rxs::range<int>(1, onnextcalls)
|