diff options
author | Elliott Hughes <enh@google.com> | 2022-09-01 14:59:27 +0000 |
---|---|---|
committer | Elliott Hughes <enh@google.com> | 2022-09-01 15:00:13 +0000 |
commit | a6661d2cf339b71de3e25f80fb927e029468c603 (patch) | |
tree | c0b1aac3621dd301e9fb7add9170d8879cc97cbe /Rx/v2/examples/doxygen/amb.cpp | |
parent | de986f59e99bd585280a061f545150ee1268f012 (diff) | |
download | RxCpp-master.tar.gz |
Do not necromance this without going through the go/android-3p process
again.
Test: treehugger
Change-Id: Id813d74d7d2597e0636b925430117c94bea3fa5a
Diffstat (limited to 'Rx/v2/examples/doxygen/amb.cpp')
-rw-r--r-- | Rx/v2/examples/doxygen/amb.cpp | 84 |
1 files changed, 0 insertions, 84 deletions
diff --git a/Rx/v2/examples/doxygen/amb.cpp b/Rx/v2/examples/doxygen/amb.cpp deleted file mode 100644 index eab7f7e..0000000 --- a/Rx/v2/examples/doxygen/amb.cpp +++ /dev/null @@ -1,84 +0,0 @@ -#include "rxcpp/rx.hpp" - -#include "rxcpp/rx-test.hpp" -#include "catch.hpp" - -SCENARIO("amb sample"){ - printf("//! [amb sample]\n"); - auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); - auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); - auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); - auto values = o1.amb(o2, o3); - values. - subscribe( - [](int v){printf("OnNext: %d\n", v);}, - [](){printf("OnCompleted\n");}); - printf("//! [amb sample]\n"); -} - -SCENARIO("implicit amb sample"){ - printf("//! [implicit amb sample]\n"); - auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); - auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); - auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); - auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3); - auto values = base.amb(); - values. - subscribe( - [](int v){printf("OnNext: %d\n", v);}, - [](){printf("OnCompleted\n");}); - printf("//! [implicit amb sample]\n"); -} - -#include "main.hpp" - -SCENARIO("threaded amb sample"){ - printf("//! [threaded amb sample]\n"); - printf("[thread %s] Start task\n", get_pid().c_str()); - auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) { - printf("[thread %s] Timer1 fired\n", get_pid().c_str()); - return 1; - }); - auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { - printf("[thread %s] Timer2 fired\n", get_pid().c_str()); - return 2; - }); - auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) { - printf("[thread %s] Timer3 fired\n", get_pid().c_str()); - return 3; - }); - auto values = o1.amb(rxcpp::observe_on_new_thread(), o2, o3); - values. - as_blocking(). - subscribe( - [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, - [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); - printf("[thread %s] Finish task\n", get_pid().c_str()); - printf("//! [threaded amb sample]\n"); -} - -SCENARIO("threaded implicit amb sample"){ - printf("//! [threaded implicit amb sample]\n"); - printf("[thread %s] Start task\n", get_pid().c_str()); - auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) { - printf("[thread %s] Timer1 fired\n", get_pid().c_str()); - return 1; - }); - auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { - printf("[thread %s] Timer2 fired\n", get_pid().c_str()); - return 2; - }); - auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) { - printf("[thread %s] Timer3 fired\n", get_pid().c_str()); - return 3; - }); - auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3); - auto values = base.amb(rxcpp::observe_on_new_thread()); - values. - as_blocking(). - subscribe( - [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);}, - [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());}); - printf("[thread %s] Finish task\n", get_pid().c_str()); - printf("//! [threaded implicit amb sample]\n"); -} |