diff options
Diffstat (limited to 'Rx/v2/examples/doxygen/on_error_resume_next.cpp')
-rw-r--r-- | Rx/v2/examples/doxygen/on_error_resume_next.cpp | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/Rx/v2/examples/doxygen/on_error_resume_next.cpp b/Rx/v2/examples/doxygen/on_error_resume_next.cpp deleted file mode 100644 index 0c9873b..0000000 --- a/Rx/v2/examples/doxygen/on_error_resume_next.cpp +++ /dev/null @@ -1,23 +0,0 @@ -#include "rxcpp/rx.hpp" -namespace rxu=rxcpp::util; - -#include "rxcpp/rx-test.hpp" -#include "catch.hpp" - -SCENARIO("on_error_resume_next sample"){ - printf("//! [on_error_resume_next sample]\n"); - auto values = rxcpp::observable<>::range(1, 3). - concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))). - on_error_resume_next([](std::exception_ptr ep){ - printf("Resuming after: %s\n", rxu::what(ep).c_str()); - return rxcpp::observable<>::just(-1); - }); - values. - subscribe( - [](int v){printf("OnNext: %d\n", v);}, - [](std::exception_ptr ep){ - printf("OnError: %s\n", rxu::what(ep).c_str()); - }, - [](){printf("OnCompleted\n");}); - printf("//! [on_error_resume_next sample]\n"); -} |