| /external/Reactive-Extensions/RxCpp/projects/CMake/ |
| D | CMakeLists.txt | 3 project(rxcpp VERSION 2.2.4 LANGUAGES C CXX) project
29 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-all.hpp
30 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-amb.hpp
31 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-any.hpp
32 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-buffer_count.hpp
33 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-buffer_time.hpp
34 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-buffer_time_count.hpp
35 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-combine_latest.hpp
36 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-concat.hpp
37 ${RXCPP_DIR}/Rx/v2/src/rxcpp/operators/rx-concat_map.hpp
[all …]
|
| /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();
20 } catch (const rxcpp::empty_error& ex) {
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();
53 } catch (const rxcpp::empty_error& ex) {
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();
[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 __anon3e0ec51c0302()
34 auto coordination = rxcpp::serialize_new_thread();
36 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
41 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c0602()
48 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anon3e0ec51c0902()
55 worker.schedule([&](const rxcpp::schedulers::schedulable&){ in __anon3e0ec51c0c02()
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 __anon3e0ec51c0f02()
91 auto coordination = rxcpp::serialize_new_thread();
[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();
25 catch (const rxcpp::empty_error& ex) { in __anon58f1cff90402()
36 auto values = rxcpp::observable<>::range(1, 3).last();
47 auto values = rxcpp::observable<>::empty<int>().last();
53 catch (const rxcpp::empty_error& ex) { in __anon58f1cff90902()
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();
[all …]
|
| D | window.cpp | 9 auto values = rxcpp::observable<>::range(1, 5).window(2);
12 [&counter](rxcpp::observable<int> v){ in __anon0463d6c70102()
25 auto values = rxcpp::observable<>::range(1, 7).window(2, 3);
28 [&counter](rxcpp::observable<int> v){ in __anon0463d6c70402()
43 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
45 window_with_time(period, skip, rxcpp::observe_on_new_thread());
49 [&counter](rxcpp::observable<long> v){ in __anon0463d6c70702()
64 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
69 [&counter](rxcpp::observable<long> v){ in __anon0463d6c70a02()
84 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
[all …]
|
| D | merge_delay_error.cpp | 2 namespace rxu=rxcpp::util;
11 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon404e2e960102()
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 __anon404e2e960202()
25 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon404e2e960602()
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 __anon404e2e960702()
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 __anon404e2e960b02()
47 …auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).flat_map([](long) -> rxcpp::ob… in __anon404e2e960c02()
[all …]
|
| D | create.cpp | 8 auto ints = rxcpp::observable<>::create<int>(
9 [](rxcpp::subscriber<int> s){ in __anona11559230102()
24 auto subscription = rxcpp::composite_subscription();
25 auto subscriber = rxcpp::make_subscriber<int>(
35 rxcpp::observable<>::create<int>(
36 [](rxcpp::subscriber<int> s){ in __anona11559230602()
49 auto subscription = rxcpp::composite_subscription();
50 auto subscriber = rxcpp::make_subscriber<int>(
60 rxcpp::observable<>::create<int>(
61 [](rxcpp::subscriber<int> s){ in __anona11559230902()
[all …]
|
| D | subscribe.cpp | 8 auto subscriber = rxcpp::make_subscriber<int>(
11 auto values = rxcpp::observable<>::range(1, 3);
18 auto subscriber = rxcpp::make_subscriber<int>(
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);
62 auto subscription = rxcpp::composite_subscription();
[all …]
|
| D | amb.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonbf9fecff0102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anonbf9fecff0202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonbf9fecff0302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonbf9fecff0602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anonbf9fecff0702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonbf9fecff0802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) { in __anonbf9fecff0b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anonbf9fecff0c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) { in __anonbf9fecff0d02()
[all …]
|
| D | merge.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon8faf7d3f0102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon8faf7d3f0202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon8faf7d3f0302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon8faf7d3f0602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon8faf7d3f0702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon8faf7d3f0802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anon8faf7d3f0b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).map([](int) { in __anon8faf7d3f0c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(30)).map([](int) { in __anon8faf7d3f0d02()
[all …]
|
| D | range.cpp | 8 auto values1 = rxcpp::observable<>::range(1, 5);
21 auto values = rxcpp::observable<>::range(1, 3, rxcpp::observe_on_new_thread());
27 rxcpp::util::apply_to(
39 auto values = rxcpp::observable<>::range(1, 3);
41 subscribe_on(rxcpp::observe_on_new_thread()).
46 rxcpp::util::apply_to(
59 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
71 subscribe(rxcpp::util::apply_to(
81 auto values = rxcpp::observable<>::range(1); // infinite (until overflow) stream of integers
93 subscribe(rxcpp::util::apply_to(
[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));
25 auto thr = rxcpp::synchronize_event_loop();
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1)).map([](int v) { in __anon3bb890620302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anon3bb890620402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anon3bb890620502()
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));
[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));
25 auto thr = rxcpp::synchronize_event_loop();
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anonadd8ac180302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anonadd8ac180402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anonadd8ac180502()
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));
[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));
25 auto thr = rxcpp::synchronize_event_loop();
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anon6b5a404a0302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anon6b5a404a0402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anon6b5a404a0502()
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));
[all …]
|
| D | publish.cpp | 11 auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
13 publish_synchronized(rxcpp::observe_on_new_thread());
29 rxcpp::observable<>::timer(std::chrono::milliseconds(75)).subscribe([&](long){ in __anon34d81aa60502()
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 __anon34d81aa60c02()
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 __anon34d81aa61302()
114 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
162 auto values = rxcpp::observable<>::iterate(a).
|
| D | error.cpp | 8 auto values = rxcpp::observable<>::error<int>(std::runtime_error("Error from source"));
12 [](rxcpp::util::error_ptr ep){ in __anonfeb848390202()
13 printf("OnError: %s\n", rxcpp::util::what(ep).c_str()); in __anonfeb848390202()
21 …auto values = rxcpp::observable<>::error<int>(std::runtime_error("Error from source"), rxcpp::obse…
26 [](rxcpp::util::error_ptr ep){ in __anonfeb848390502()
27 printf("OnError: %s\n", rxcpp::util::what(ep).c_str()); in __anonfeb848390502()
|
| D | timestamp.cpp | 9 typedef rxcpp::schedulers::scheduler::clock_type::time_point time_point;
12 auto values = rxcpp::observable<>::interval(milliseconds(100))
15 time_point start = rxcpp::identity_current_thread().now();
34 using namespace rxcpp;
35 using namespace rxcpp::sources;
36 using namespace rxcpp::operators;
39 typedef rxcpp::schedulers::scheduler::clock_type::time_point time_point;
45 time_point start = rxcpp::identity_current_thread().now();
|
| 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…
51 buffer_with_time(period, skip, rxcpp::observe_on_new_thread());
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…
130 buffer_with_time(std::chrono::milliseconds(4), rxcpp::observe_on_new_thread());
147 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
[all …]
|
| 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 __anon6529427f0502()
38 auto trigger = rxcpp::observable<>::timer(std::chrono::milliseconds(25)).map([](long v){ in __anon6529427f0602()
42 auto values = source.take_until(trigger, rxcpp::observe_on_new_thread());
55 … auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){ in __anon6529427f0902()
59 auto scheduler = rxcpp::observe_on_new_thread();
|
| 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 __anon01d19d5b0102()
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 __anon01d19d5b0402()
28 auto values = base.switch_on_next(rxcpp::observe_on_new_thread()).take(10);
|
| D | time_interval.cpp | 9 typedef rxcpp::schedulers::scheduler::clock_type::time_point::duration duration_type;
12 auto values = rxcpp::observable<>::interval(milliseconds(100))
33 using namespace rxcpp;
34 using namespace rxcpp::sources;
35 using namespace rxcpp::operators;
38 typedef rxcpp::schedulers::scheduler::clock_type::time_point::duration duration_type;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/pythagorian/ |
| D | main.cpp | 4 struct trace_calls : rxcpp::trace_noop
95 auto rxcpp_trace_activity(rxcpp::trace_tag) -> trace_calls;
101 namespace rx=rxcpp;
102 namespace rxu=rxcpp::util;
142 …<< "onnexts: " << rxcpp::trace_activity().onnexts << ", onerrors: " << rxcpp::trace_activity().one… in wmain()
143 …std::cout << "subscribes: " << rxcpp::trace_activity().subscribes << ", lifts: " << rxcpp::trace_a… in wmain()
144 …< "unsubscribes: " << rxcpp::trace_activity().unsubscribes << ", adds: " << rxcpp::trace_activity(… in wmain()
145 …std::cout << "schedules: " << rxcpp::trace_activity().schedules << ", schedulewhens: " << rxcpp::t… in wmain()
146 …std::cout << "actions: " << rxcpp::trace_activity().actions << ", recurses: " << rxcpp::trace_acti… in wmain()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/ |
| D | test.h | 11 namespace rx=rxcpp;
12 namespace rxu=rxcpp::util;
13 namespace rxs=rxcpp::sources;
14 namespace rxo=rxcpp::operators;
15 namespace rxsub=rxcpp::subjects;
16 namespace rxsc=rxcpp::schedulers;
20 namespace rxt = rxcpp::test;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coroutine.hpp | 26 namespace rxcpp { namespace
183 auto begin(const rxcpp::observable<T, SourceOperator>& o) in begin()
184 -> rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>> { in begin()
185 … return rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>>{o}; in begin()
189 auto end(const rxcpp::observable<T, SourceOperator>&) in end()
190 -> rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>> { in end()
191 return rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>>{}; in end()
|