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");
-}