1 files changed, 0 insertions, 84 deletions
diff --git a/Rx/v2/examples/doxygen/retry.cpp b/Rx/v2/examples/doxygen/retry.cpp
deleted file mode 100644
index efcfb23..0000000
--- a/Rx/v2/examples/doxygen/retry.cpp
+++ /dev/null
@@ -1,84 +0,0 @@
-#include "rxcpp/rx.hpp"
-
-#include "rxcpp/rx-test.hpp"
-#include "catch.hpp"
-
-SCENARIO("retry sample"){
-    printf("//! [retry sample]\n");
-    auto values = rxcpp::observable<>::from(1, 2).
-        concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
-        retry().
-        take(5);
-    values.
-        subscribe(
-            [](int v){printf("OnNext: %d\n", v);},
-            [](){printf("OnCompleted\n");});
-    printf("//! [retry sample]\n");
-}
-
-SCENARIO("retry count sample"){
-    printf("//! [retry count sample]\n");
-    auto source = rxcpp::observable<>::from(1, 2).
-        concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
-    auto values = source.retry(3);
-    values.
-        subscribe(
-            [](int v){printf("OnNext: %d\n", v);},
-            [](std::exception_ptr ep){
-                try {std::rethrow_exception(ep);}
-                catch (const std::exception& ex) {
-                    printf("OnError: %s\n", ex.what());
-                }
-            },
-            [](){printf("OnCompleted\n");});
-    printf("//! [retry count sample]\n");
-}
-
-//SCENARIO("retry hot sample"){
-//    printf("//! [retry hot sample]\n");
-//    auto values = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).
-//        concat(rxcpp::observable<>::error<long>(std::runtime_error("Error1 from source"))).
-//        concat(rxcpp::observable<>::timer(std::chrono::milliseconds(10))).
-//        concat(rxcpp::observable<>::error<long>(std::runtime_error("Error2 from source"))).
-//        concat(rxcpp::observable<>::timer(std::chrono::milliseconds(10))).
-//        concat(rxcpp::observable<>::error<long>(std::runtime_error("Error3 from source"))).
-//        concat(rxcpp::observable<>::timer(std::chrono::milliseconds(10))).
-//        concat(rxcpp::observable<>::error<long>(std::runtime_error("Error4 from source"))).
-//        retry(3);
-//    values.
-//        subscribe(
-//            [](long v){printf("OnNext: %d\n", v);},
-//            [](std::exception_ptr ep){
-//                try {std::rethrow_exception(ep);}
-//                catch (const std::exception& ex) {
-//                    printf("OnError: %s\n", ex.what());
-//                }
-//            },
-//            [](){printf("OnCompleted\n");});
-//    printf("//! [retry hot sample]\n");
-//}
-//
-//SCENARIO("retry completed sample"){
-//    printf("//! [retry completed sample <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<]\n");
-//    auto source = rxcpp::observable<>::from(1, 2).
-//        concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
-//        publish();
-//    auto values = source.retry();
-//    //auto values = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).
-//    //    concat(rxcpp::observable<>::error<long>(std::runtime_error("Error1 from source"))).
-//    //    concat(rxcpp::observable<>::timer(std::chrono::milliseconds(10))).
-//    //    concat(rxcpp::observable<>::error<long>(std::runtime_error("Error2 from source"))).
-//    //    concat(rxcpp::observable<>::timer(std::chrono::milliseconds(10))).
-//    //    retry(3);
-//    values.
-//        subscribe(
-//            [](long v){printf("OnNext: %d\n", v);},
-//            [](std::exception_ptr ep){
-//                try {std::rethrow_exception(ep);}
-//                catch (const std::exception& ex) {
-//                    printf("OnError: %s\n", ex.what());
-//                }
-//            },
-//            [](){printf("OnCompleted\n");});
-//    printf("//! [retry completed sample]\n");
-//}