Searched refs:observe_on_new_thread (Results 1 – 25 of 25) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | publish.cpp | 13 publish_synchronized(rxcpp::observe_on_new_thread());
42 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
73 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
114 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
|
| D | timer.cpp | 30 auto scheduler = rxcpp::observe_on_new_thread();
43 auto scheduler = rxcpp::observe_on_new_thread();
|
| D | replay.cpp | 10 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
67 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
124 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
181 …ues = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_thread()).
|
| D | concat.cpp | 38 auto values = o1.concat(rxcpp::observe_on_new_thread(), o2, o3);
53 auto values = base.concat(rxcpp::observe_on_new_thread());
|
| D | take_until.cpp | 42 auto values = source.take_until(trigger, rxcpp::observe_on_new_thread());
59 auto scheduler = rxcpp::observe_on_new_thread();
|
| D | amb.cpp | 50 auto values = o1.amb(rxcpp::observe_on_new_thread(), o2, o3);
76 auto values = base.amb(rxcpp::observe_on_new_thread());
|
| D | merge.cpp | 50 auto values = o1.merge(rxcpp::observe_on_new_thread(), o2, o3);
76 auto values = base.merge(rxcpp::observe_on_new_thread());
|
| D | range.cpp | 21 auto values = rxcpp::observable<>::range(1, 3, rxcpp::observe_on_new_thread());
41 subscribe_on(rxcpp::observe_on_new_thread()).
|
| D | merge_delay_error.cpp | 59 auto values = o1.merge(rxcpp::observe_on_new_thread(), o2, o3);
90 auto values = base.merge(rxcpp::observe_on_new_thread());
|
| D | window.cpp | 45 window_with_time(period, skip, rxcpp::observe_on_new_thread());
123 window_with_time(std::chrono::milliseconds(4), rxcpp::observe_on_new_thread());
206 rxcpp::observe_on_new_thread());
|
| D | from.cpp | 21 auto values = rxcpp::observable<>::from(rxcpp::observe_on_new_thread(), 1, 2, 3).map([](int v){ in __anonf473b6030302()
|
| D | switch_on_next.cpp | 28 auto values = base.switch_on_next(rxcpp::observe_on_new_thread()).take(10);
|
| D | skip_until.cpp | 31 auto values = source.skip_until(trigger, rxcpp::observe_on_new_thread());
|
| D | delay.cpp | 22 delay(period, rxcpp::observe_on_new_thread());
|
| D | buffer.cpp | 51 buffer_with_time(period, skip, rxcpp::observe_on_new_thread());
130 buffer_with_time(std::chrono::milliseconds(4), rxcpp::observe_on_new_thread());
|
| D | concat_map.cpp | 42 rxcpp::observe_on_new_thread());
|
| D | flat_map.cpp | 42 rxcpp::observe_on_new_thread());
|
| D | combine_latest.cpp | 73 rxcpp::observe_on_new_thread(),
|
| D | with_latest_from.cpp | 73 rxcpp::observe_on_new_thread(),
|
| D | zip.cpp | 73 rxcpp::observe_on_new_thread(),
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
| D | main.cpp | 26 .subscribe_on(rx::observe_on_new_thread()) in main()
39 .subscribe_on(rx::observe_on_new_thread()) in main()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | group_by.cpp | 29 …auto outputthread = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinator…
54 …auto producerthread = rxcpp::observe_on_one_worker(rxcpp::observe_on_new_thread().create_coordinat… in __anondfad2d780502()
132 … return rxcpp::observable<>::range(w.first, w.last, rxcpp::observe_on_new_thread()). in __anondfad2d780b02()
144 merge(rxcpp::observe_on_new_thread()).
|
| D | observe_on.cpp | 15 auto el = rx::observe_on_new_thread();
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 30 * ```observe_on_new_thread()```
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 328 inline observe_on_one_worker observe_on_new_thread() { in observe_on_new_thread() function
|