summaryrefslogtreecommitdiff
path: root/Rx/v2/examples/doxygen/amb.cpp
diff options
context:
space:
mode:
authorElliott Hughes <enh@google.com>2022-09-01 14:59:27 +0000
committerElliott Hughes <enh@google.com>2022-09-01 15:00:13 +0000
commita6661d2cf339b71de3e25f80fb927e029468c603 (patch)
treec0b1aac3621dd301e9fb7add9170d8879cc97cbe /Rx/v2/examples/doxygen/amb.cpp
parentde986f59e99bd585280a061f545150ee1268f012 (diff)
downloadRxCpp-master.tar.gz
Remove RxCpp, which is no longer used.HEADmastermain
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.cpp84
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");
-}