Merge pull request #1 from kirkshoop/callonerror

how-to-call-on-error-on-a-custom-rxcpp-operator
cipriancaba · Feb 6, 2017 · 64cfdbc · 64cfdbc
2 parents 35cb23c + 4628c01
commit 64cfdbc
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/SimpleOperators.cpp b/src/SimpleOperators.cpp
@@ -7,8 +7,11 @@
 function<observable<json>(observable<string>)> SimpleOperators::convertFromStringToJson() {
   return [](observable<string> $str) {
     return $str |
-      Rx::map([](const string s) {
-        return json::parse(s);
+      Rx::map([](const string& s) {
+          return json::parse(s);
+      }) |
+      Rx::on_error_resume_next([](std::exception_ptr){
+        return Rx::error<json>(runtime_error("custom exception"));
       });
   };
 }