Searched refs:observe_on_event_loop (Results 1 – 17 of 17) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/awaitable/ |
| D | main.cpp | 19 for co_await (auto c : interval(seconds(1), observe_on_event_loop())) { in intervals()
27 for co_await (auto c : interval(seconds(1), observe_on_event_loop()) | take(3)) { in intervals()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | subscribe_on.cpp | 37 .subscribe_on(rx::observe_on_event_loop())
38 .observe_on(rx::observe_on_event_loop())
79 subscribe_on(rx::observe_on_event_loop()).
|
| D | concat.cpp | 43 auto so = rx::observe_on_event_loop();
|
| D | merge.cpp | 44 auto so = rx::observe_on_event_loop();
|
| D | concat_map.cpp | 111 auto so = rx::observe_on_event_loop();
|
| D | flat_map.cpp | 147 auto so = rx::observe_on_event_loop();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | range.cpp | 102 auto threads = rxcpp::observe_on_event_loop();
129 auto threads = rxcpp::observe_on_event_loop();
|
| D | just.cpp | 18 auto values = rxcpp::observable<>::just(1, rxcpp::observe_on_event_loop());
|
| D | iterate.cpp | 20 auto values = rxcpp::observable<>::iterate(a, rxcpp::observe_on_event_loop());
|
| D | empty.cpp | 18 auto values = rxcpp::observable<>::empty<int>(rxcpp::observe_on_event_loop());
|
| D | error.cpp | 21 …:observable<>::error<int>(std::runtime_error("Error from source"), rxcpp::observe_on_event_loop());
|
| D | switch_on_next.cpp | 26 …cpp::observable<>::interval(std::chrono::milliseconds(10), rxcpp::observe_on_event_loop()).as_dyna… in __anond8561df40402()
|
| D | buffer.cpp | 169 buffer_with_time_or_count(std::chrono::milliseconds(20), 2, rxcpp::observe_on_event_loop());
|
| D | window.cpp | 162 window_with_time_or_count(std::chrono::milliseconds(20), 2, rxcpp::observe_on_event_loop());
|
| /external/Reactive-Extensions/RxCpp/ |
| D | DeveloperManual.md | 29 * ```observe_on_event_loop()```
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 323 inline observe_on_one_worker observe_on_event_loop() { in observe_on_event_loop() function
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 230 auto es = rx::observe_on_event_loop();
|