| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | blocking_observable.cpp | 8 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
16 auto values = rxcpp::observable<>::empty<int>().as_blocking();
28 auto values = rxcpp::observable<>::error<int>(std::runtime_error("Error from source")).
41 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
49 auto values = rxcpp::observable<>::empty<int>().as_blocking();
61 auto values = rxcpp::observable<>::range(1, 3).
62 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
75 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
83 auto values = rxcpp::observable<>::range(1, 3).
84 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
[all …]
|
| D | window.cpp | 9 auto values = rxcpp::observable<>::range(1, 5).window(2);
12 [&counter](rxcpp::observable<int> v){ in __anon5e81ce600102()
25 auto values = rxcpp::observable<>::range(1, 7).window(2, 3);
28 [&counter](rxcpp::observable<int> v){ in __anon5e81ce600402()
43 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
49 [&counter](rxcpp::observable<long> v){ in __anon5e81ce600702()
64 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
69 [&counter](rxcpp::observable<long> v){ in __anon5e81ce600a02()
84 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
89 [&counter](rxcpp::observable<long> v){ in __anon5e81ce600d02()
[all …]
|
| D | concat.cpp | 8 auto o1 = rxcpp::observable<>::range(1, 3);
9 auto o2 = rxcpp::observable<>::just(4);
10 auto o3 = rxcpp::observable<>::from(5, 6);
21 auto o1 = rxcpp::observable<>::range(1, 3);
22 auto o2 = rxcpp::observable<>::just(4);
23 auto o3 = rxcpp::observable<>::from(5, 6);
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
35 auto o1 = rxcpp::observable<>::range(1, 3);
36 auto o2 = rxcpp::observable<>::just(4);
37 auto o3 = rxcpp::observable<>::from(5, 6);
[all …]
|
| D | math.cpp | 8 auto values = rxcpp::observable<>::range(1, 3).first();
19 auto values = rxcpp::observable<>::empty<int>().first();
36 auto values = rxcpp::observable<>::range(1, 3).last();
47 auto values = rxcpp::observable<>::empty<int>().last();
64 auto values = rxcpp::observable<>::range(1, 3).count();
75 auto values = rxcpp::observable<>::range(1, 3).
76 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
94 auto values = rxcpp::observable<>::range(1, 3).sum();
105 auto values = rxcpp::observable<>::empty<int>().sum();
122 auto values = rxcpp::observable<>::range(1, 3).
[all …]
|
| D | merge_delay_error.cpp | 11 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonfed6948f0102()
12 auto o2 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source\n"));
13 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonfed6948f0202()
25 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonfed6948f0602()
26 auto o2 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source\n"));
27 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonfed6948f0702()
28 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
43 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](long) -> long { in __anonfed6948f0b02()
47 …auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).flat_map([](long) -> rxcpp::ob… in __anonfed6948f0c02()
53 return rxcpp::observable<>::error<long>(std::runtime_error(ss.str())); in __anonfed6948f0c02()
[all …]
|
| D | merge.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anona9b065b80102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anona9b065b80202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anona9b065b80302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anona9b065b80602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anona9b065b80702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anona9b065b80802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anona9b065b80b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).map([](int) { in __anona9b065b80c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(30)).map([](int) { in __anona9b065b80d02()
[all …]
|
| D | amb.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon4d2a63380102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon4d2a63380202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon4d2a63380302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon4d2a63380602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon4d2a63380702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon4d2a63380802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) { in __anon4d2a63380b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anon4d2a63380c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) { in __anon4d2a63380d02()
[all …]
|
| D | subscribe.cpp | 11 auto values = rxcpp::observable<>::range(1, 3);
21 auto values1 = rxcpp::observable<>::range(1, 3);
22 auto values2 = rxcpp::observable<>::range(4, 6);
30 auto values = rxcpp::observable<>::range(1, 3);
38 auto values = rxcpp::observable<>::range(1, 3).
39 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
53 auto values = rxcpp::observable<>::range(1, 3);
63 auto values = rxcpp::observable<>::range(1, 5);
77 auto values = rxcpp::observable<>::range(1, 3).
78 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
[all …]
|
| D | combine_latest.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anon845d2cb10302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anon845d2cb10402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anon845d2cb10502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
[all …]
|
| D | with_latest_from.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anonf5014b230302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anonf5014b230402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anonf5014b230502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
[all …]
|
| D | zip.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1)).map([](int v) { in __anonc943069b0302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anonc943069b0402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anonc943069b0502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
[all …]
|
| D | buffer.cpp | 8 auto values = rxcpp::observable<>::range(1, 5).buffer(2);
24 auto values = rxcpp::observable<>::range(1, 7).buffer(2, 3);
45 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
71 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
91 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
111 auto values = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).
128 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
147 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
165 auto int1 = rxcpp::observable<>::range(1L, 3L);
166 auto int2 = rxcpp::observable<>::timer(std::chrono::milliseconds(50));
[all …]
|
| D | replay.cpp | 10 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
23 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon982cbcb50302()
36 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
67 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
80 rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){ in __anon982cbcb50f02()
93 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
124 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
137 rxcpp::observable<>::timer(std::chrono::milliseconds(175)).subscribe([&](long){ in __anon982cbcb51b02()
150 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
181 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
[all …]
|
| D | publish.cpp | 11 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
29 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anond2b5055f0502()
42 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
60 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anond2b5055f0c02()
73 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
91 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anond2b5055f1302()
114 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
162 auto values = rxcpp::observable<>::iterate(a).
|
| D | start_with.cpp | 8 auto observable = rxcpp::observable<>::range(10, 12); variable
9 auto values = rxcpp::observable<>::start_with(observable, 1, 2, 3);
19 auto values = rxcpp::observable<>::range(10, 12).
|
| D | take_until.cpp | 8 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
9 auto trigger = rxcpp::observable<>::timer(std::chrono::milliseconds(25));
20 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
34 … auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){ in __anon063b5e980502()
38 auto trigger = rxcpp::observable<>::timer(std::chrono::milliseconds(25)).map([](long v){ in __anon063b5e980602()
55 … auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){ in __anon063b5e980902()
|
| D | range.cpp | 8 auto values1 = rxcpp::observable<>::range(1, 5);
21 auto values = rxcpp::observable<>::range(1, 3, rxcpp::observe_on_new_thread());
39 auto values = rxcpp::observable<>::range(1, 3);
59 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
81 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
104 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
131 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
|
| D | retry.cpp | 8 auto values = rxcpp::observable<>::from(1, 2).
9 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
21 auto source = rxcpp::observable<>::from(1, 2).
22 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
|
| D | switch_on_next.cpp | 8 auto base = rxcpp::observable<>::interval(std::chrono::milliseconds(30)).
11 return rxcpp::observable<>::interval(std::chrono::milliseconds(10)).as_dynamic(); in __anond8561df40102()
23 auto base = rxcpp::observable<>::interval(std::chrono::milliseconds(30)).
26 …return rxcpp::observable<>::interval(std::chrono::milliseconds(10), rxcpp::observe_on_event_loop()… in __anond8561df40402()
|
| D | repeat.cpp | 8 auto values = rxcpp::observable<>::from(1, 2).
20 auto values = rxcpp::observable<>::from(1, 2).repeat(3);
30 auto values = rxcpp::observable<>::from(1, 2).
31 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | defer.cpp | 15 auto empty = rx::observable<>::empty<long>();
16 auto just = rx::observable<>::just(42);
17 auto one = rx::observable<>::from(42);
18 auto error = rx::observable<>::error<long>(rxu::error_ptr());
19 auto runtimeerror = rx::observable<>::error<long>(std::runtime_error("runtime"));
23 return rx::observable<>::defer( in __anon03ff71350102()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-range.hpp | 120 -> observable<T, detail::range<T, identity_one_worker>> { in range()
121 return observable<T, detail::range<T, identity_one_worker>>( in range()
128 -> observable<T, detail::range<T, Coordination>> { in range()
129 return observable<T, detail::range<T, Coordination>>( in range()
137 observable<T, detail::range<T, Coordination>>>::type { in range()
138 return observable<T, detail::range<T, Coordination>>( in range()
146 observable<T, detail::range<T, Coordination>>>::type { in range()
147 return observable<T, detail::range<T, Coordination>>( in range()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-merge.hpp | 59 using type = observable<merge_invalid_arguments<AN...>, merge_invalid<AN...>>;
117 observable<source_value_type, source_operator_type> source; in on_subscribe()
232 class Result = observable<Value, Merge>
245 class Result = observable<Value, Merge>
255 class SourceValue = observable<EmittedValue>,
256 class ObservableObservable = observable<SourceValue>,
259 class Result = observable<Value, Merge>
270 class SourceValue = observable<EmittedValue>,
271 class ObservableObservable = observable<SourceValue>,
274 class Result = observable<Value, Merge>
|
| D | rx-amb.hpp | 55 using type = observable<amb_invalid_arguments<AN...>, amb_invalid<AN...>>;
114 observable<source_value_type, source_operator_type> source; in on_subscribe()
240 class Result = observable<Value, Amb>
253 class Result = observable<Value, Amb>
263 class SourceValue = observable<EmittedValue>,
264 class ObservableObservable = observable<SourceValue>,
267 class Result = observable<Value, Amb>
278 class SourceValue = observable<EmittedValue>,
279 class ObservableObservable = observable<SourceValue>,
282 class Result = observable<Value, Amb>
|
| D | rx-concat.hpp | 57 using type = observable<concat_invalid_arguments<AN...>, concat_invalid<AN...>>;
169 observable<source_value_type, source_operator_type> source; in on_subscribe()
251 class Result = observable<Value, Concat>
264 class Result = observable<Value, Concat>
274 class SourceValue = observable<EmittedValue>,
275 class ObservableObservable = observable<SourceValue>,
278 class Result = observable<Value, Concat>
289 class SourceValue = observable<EmittedValue>,
290 class ObservableObservable = observable<SourceValue>,
293 class Result = observable<Value, Concat>
|