| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | replay.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
33 w.schedule_absolute(rxsc::test::created_time,
34 [&ys, &xs](const rxsc::schedulable&){ in __anon9c790cfe0102()
38 w.schedule_absolute(rxsc::test::subscribed_time,
39 [&ys, &res](const rxsc::schedulable&){ in __anon9c790cfe0202()
43 w.schedule_absolute(rxsc::test::unsubscribed_time,
44 [&res](const rxsc::schedulable&){ in __anon9c790cfe0302()
52 [connection, &ys](const rxsc::schedulable&){ in __anon9c790cfe0402()
56 [connection](const rxsc::schedulable&){ in __anon9c790cfe0502()
[all …]
|
| D | publish.cpp | 143 auto sc = rxsc::make_test();
145 const rxsc::test::messages<int> on;
170 w.schedule_absolute(rxsc::test::created_time,
171 [&ys, &xs](const rxsc::schedulable&){ in __anon608b5ec81202()
176 w.schedule_absolute(rxsc::test::subscribed_time,
177 [&ys, &res](const rxsc::schedulable&){ in __anon608b5ec81302()
181 w.schedule_absolute(rxsc::test::unsubscribed_time,
182 [&res](const rxsc::schedulable&){ in __anon608b5ec81402()
190 [connection, &ys](const rxsc::schedulable&){ in __anon608b5ec81502()
194 [connection](const rxsc::schedulable&){ in __anon608b5ec81602()
[all …]
|
| D | sequence_equal.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
34 auto required = std::vector<rxsc::test::messages<bool>::recorded_type>();
52 auto sc = rxsc::make_test();
54 const rxsc::test::messages<int> on;
80 auto required = std::vector<rxsc::test::messages<bool>::recorded_type>();
98 auto sc = rxsc::make_test();
100 const rxsc::test::messages<int> on;
121 auto required = std::vector<rxsc::test::messages<bool>::recorded_type>();
139 auto sc = rxsc::make_test();
[all …]
|
| D | reduce.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
61 auto sc = rxsc::make_test();
63 const rxsc::test::messages<int> on;
116 auto sc = rxsc::make_test();
118 const rxsc::test::messages<int> on;
119 const rxsc::test::messages<double> d_on;
159 auto sc = rxsc::make_test();
161 const rxsc::test::messages<int> on;
162 const rxsc::test::messages<int> d_on;
[all …]
|
| D | time_interval.cpp | 8 typedef rxsc::detail::test_type::clock_type::time_point::duration duration;
10 auto sc = rxsc::make_test();
12 const rxsc::test::messages<int> on;
28 auto required = std::vector<rxsc::test::messages<duration>::recorded_type>();
46 typedef rxsc::detail::test_type::clock_type::time_point::duration duration;
48 auto sc = rxsc::make_test();
51 const rxsc::test::messages<int> on;
52 const rxsc::test::messages<duration> on_time_interval;
89 typedef rxsc::detail::test_type::clock_type clock_type;
92 auto sc = rxsc::make_test();
[all …]
|
| D | contains.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
9 const rxsc::test::messages<bool> on_contains;
50 auto sc = rxsc::make_test();
52 const rxsc::test::messages<int> on;
53 const rxsc::test::messages<bool> on_contains;
94 auto sc = rxsc::make_test();
96 const rxsc::test::messages<int> on;
97 const rxsc::test::messages<bool> on_contains;
135 auto sc = rxsc::make_test();
[all …]
|
| D | exists.cpp | 8 auto sc = rxsc::make_test();
10 const rxsc::test::messages<int> on;
11 const rxsc::test::messages<bool> on_exists;
52 auto sc = rxsc::make_test();
54 const rxsc::test::messages<int> on;
55 const rxsc::test::messages<bool> on_exists;
97 auto sc = rxsc::make_test();
99 const rxsc::test::messages<int> on;
100 const rxsc::test::messages<bool> on_exists;
138 auto sc = rxsc::make_test();
[all …]
|
| D | any.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
9 const rxsc::test::messages<bool> on_any;
50 auto sc = rxsc::make_test();
52 const rxsc::test::messages<int> on;
53 const rxsc::test::messages<bool> on_any;
95 auto sc = rxsc::make_test();
97 const rxsc::test::messages<int> on;
98 const rxsc::test::messages<bool> on_any;
136 auto sc = rxsc::make_test();
[all …]
|
| D | all.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
9 const rxsc::test::messages<bool> on_all;
51 auto sc = rxsc::make_test();
53 const rxsc::test::messages<int> on;
54 const rxsc::test::messages<bool> on_all;
97 auto sc = rxsc::make_test();
99 const rxsc::test::messages<int> on;
100 const rxsc::test::messages<bool> on_all;
139 auto sc = rxsc::make_test();
[all …]
|
| D | timestamp.cpp | 8 typedef rxsc::detail::test_type::clock_type::time_point time_point;
10 auto sc = rxsc::make_test();
12 const rxsc::test::messages<int> on;
28 … auto required = std::vector<rxsc::test::messages<std::pair<int, time_point>>::recorded_type>();
46 typedef rxsc::detail::test_type::clock_type::time_point time_point;
48 auto sc = rxsc::make_test();
51 const rxsc::test::messages<int> on;
52 const rxsc::test::messages<std::pair<int, time_point>> on_timestamp;
89 typedef rxsc::detail::test_type::clock_type clock_type;
92 auto sc = rxsc::make_test();
[all …]
|
| D | window.cpp | 11 auto sc = rxsc::make_test();
13 const rxsc::test::messages<int> on;
14 const rxsc::test::messages<rx::observable<int>> o_on;
72 auto sc = rxsc::make_test();
74 const rxsc::test::messages<int> on;
75 const rxsc::test::messages<rx::observable<int>> o_on;
96 rxsc::test::created_time,
97 [&](const rxsc::schedulable&) { in __anon62ce1ea90202()
104 rxsc::test::subscribed_time,
105 [&](const rxsc::schedulable&) { in __anon62ce1ea90302()
[all …]
|
| D | buffer.cpp | 10 auto sc = rxsc::make_test();
12 const rxsc::test::messages<int> on;
13 const rxsc::test::messages<std::vector<int>> v_on;
57 auto sc = rxsc::make_test();
59 const rxsc::test::messages<int> on;
60 const rxsc::test::messages<std::vector<int>> v_on;
105 auto sc = rxsc::make_test();
107 const rxsc::test::messages<int> on;
108 const rxsc::test::messages<std::vector<int>> v_on;
153 auto sc = rxsc::make_test();
[all …]
|
| D | is_empty.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
9 const rxsc::test::messages<bool> on_is_empty;
51 auto sc = rxsc::make_test();
53 const rxsc::test::messages<int> on;
54 const rxsc::test::messages<bool> on_is_empty;
93 auto sc = rxsc::make_test();
95 const rxsc::test::messages<int> on;
96 const rxsc::test::messages<bool> on_is_empty;
113 auto required = std::vector<rxsc::test::messages<bool>::recorded_type>();
[all …]
|
| D | zip.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
35 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
61 auto sc = rxsc::make_test();
63 const rxsc::test::messages<int> on;
93 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
114 auto sc = rxsc::make_test();
116 const rxsc::test::messages<int> on;
144 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
170 auto sc = rxsc::make_test();
[all …]
|
| D | combine_latest.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
76 auto sc = rxsc::make_test();
78 const rxsc::test::messages<int> on;
141 auto sc = rxsc::make_test();
143 const rxsc::test::messages<int> on;
206 auto sc = rxsc::make_test();
208 const rxsc::test::messages<int> on;
273 auto sc = rxsc::make_test();
275 const rxsc::test::messages<int> on;
[all …]
|
| D | with_latest_from.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
75 auto sc = rxsc::make_test();
77 const rxsc::test::messages<int> on;
140 auto sc = rxsc::make_test();
142 const rxsc::test::messages<int> on;
205 auto sc = rxsc::make_test();
207 const rxsc::test::messages<int> on;
272 auto sc = rxsc::make_test();
274 const rxsc::test::messages<int> on;
[all …]
|
| D | skip_until.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
67 auto sc = rxsc::make_test();
69 const rxsc::test::messages<int> on;
127 auto sc = rxsc::make_test();
129 const rxsc::test::messages<int> on;
185 auto sc = rxsc::make_test();
187 const rxsc::test::messages<int> on;
215 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
241 auto sc = rxsc::make_test();
[all …]
|
| D | distinct_until_changed.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
23 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
41 auto sc = rxsc::make_test();
43 const rxsc::test::messages<int> on;
80 auto sc = rxsc::make_test();
82 const rxsc::test::messages<int> on;
121 auto sc = rxsc::make_test();
123 const rxsc::test::messages<int> on;
162 auto sc = rxsc::make_test();
[all …]
|
| D | element_at.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
23 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
41 auto sc = rxsc::make_test();
43 const rxsc::test::messages<int> on;
82 auto sc = rxsc::make_test();
84 const rxsc::test::messages<int> on;
123 auto sc = rxsc::make_test();
125 const rxsc::test::messages<int> on;
164 auto sc = rxsc::make_test();
[all …]
|
| D | distinct.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
26 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
44 auto sc = rxsc::make_test();
46 const rxsc::test::messages<int> on;
85 auto sc = rxsc::make_test();
87 const rxsc::test::messages<int> on;
128 auto sc = rxsc::make_test();
130 const rxsc::test::messages<int> on;
171 auto sc = rxsc::make_test();
[all …]
|
| D | amb.cpp | 6 auto sc = rxsc::make_test();
8 const rxsc::test::messages<int> on;
9 const rxsc::test::messages<rx::observable<int>> o_on;
42 auto required = std::vector<rxsc::test::messages<int>::recorded_type>();
84 auto sc = rxsc::make_test();
86 const rxsc::test::messages<int> on;
87 const rxsc::test::messages<rx::observable<int>> o_on;
152 auto sc = rxsc::make_test();
154 const rxsc::test::messages<int> on;
155 const rxsc::test::messages<rx::observable<int>> o_on;
[all …]
|
| D | take_until.cpp | 7 auto sc = rxsc::make_test();
9 const rxsc::test::messages<int> on;
69 auto sc = rxsc::make_test();
71 const rxsc::test::messages<int> on;
131 auto sc = rxsc::make_test();
133 const rxsc::test::messages<int> on;
194 auto sc = rxsc::make_test();
196 const rxsc::test::messages<int> on;
257 auto sc = rxsc::make_test();
259 const rxsc::test::messages<int> on;
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coordination.hpp | 78 … rxsc::detail::is_action_function<T>::value, get_action_function<T>, typename std::conditional<
85 rxsc::worker get_worker() const { in get_worker()
88 rxsc::scheduler get_scheduler() const { in get_scheduler()
110 …static_assert(rxsc::detail::is_action_function<F>::value, "can only synchronize action functions"); in act()
116 rxsc::scheduler factory;
120 rxsc::worker controller;
121 rxsc::scheduler factory;
123 explicit input_type(rxsc::worker w) in input_type()
125 , factory(rxsc::make_same_worker(w)) in input_type()
128 inline rxsc::worker get_worker() const { in get_worker()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-interval.hpp | 54 …interval_initial_type(rxsc::scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::dura… in interval_initial_type()
60 rxsc::scheduler::clock_type::time_point initial;
61 rxsc::scheduler::clock_type::duration period;
66 …interval(rxsc::scheduler::clock_type::time_point i, rxsc::scheduler::clock_type::duration p, coord… in interval()
81 auto producer = [o, counter](const rxsc::schedulable&) { in on_subscribe()
100 std::is_convertible<Duration, rxsc::scheduler::clock_type::duration>::value,
123 auto interval(rxsc::scheduler::clock_type::duration period, Coordination cn) in interval()
125 … detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::value, in interval()
126 …typename detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::observabl… in interval()
127 …return detail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::make(… in interval()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | interval.cpp | 9 auto sc = rxsc::make_current_thread();
14 [=, &c](rxsc::schedulable scbl){ in __anon75bcabbb0102()
31 auto sc = rxsc::make_current_thread();
35 rxsc::current_thread::clock_type::duration initial,
36 rxsc::current_thread::clock_type::duration period,
37 rxsc::schedulable activity){ in __anon75bcabbb0202()
38 auto periodic = rxsc::make_schedulable( in __anon75bcabbb0202()
40 [period, activity](rxsc::schedulable self) { in __anon75bcabbb0202()
43 rxsc::recursion r(false); in __anon75bcabbb0202()
57 rxsc::make_schedulable(w, [=, &c](rxsc::schedulable scbl){ in __anon75bcabbb0402()
[all …]
|