diff options
Diffstat (limited to 'Rx/v2/examples/doxygen/composite_exception.cpp')
-rw-r--r-- | Rx/v2/examples/doxygen/composite_exception.cpp | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/Rx/v2/examples/doxygen/composite_exception.cpp b/Rx/v2/examples/doxygen/composite_exception.cpp new file mode 100644 index 0000000..697b83f --- /dev/null +++ b/Rx/v2/examples/doxygen/composite_exception.cpp @@ -0,0 +1,31 @@ +#include "rxcpp/rx.hpp" +namespace rxu=rxcpp::util; + +#include "rxcpp/rx-test.hpp" +#include "catch.hpp" + +SCENARIO("composite_exception sample"){ + printf("//! [composite_exception sample]\n"); + auto o1 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source o1\n")); + auto o2 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source o2\n")); + auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); + auto values = o1.merge_delay_error(o2, o3); + values. + subscribe( + [](int v){printf("OnNext: %d\n", v);}, + [](std::exception_ptr composite_e) { + printf("OnError %s\n", rxu::what(composite_e).c_str()); + try { std::rethrow_exception(composite_e); } + catch(rxcpp::composite_exception ce) { + for(std::exception_ptr particular_e : ce.exceptions) { + + try{ std::rethrow_exception(particular_e); } + catch(std::runtime_error error) { printf(" *** %s\n", error.what()); } + + } + } + }, + [](){printf("OnCompleted\n");} + ); + printf("//! [composite_exception sample]\n"); +} |