just wrap into an exception to rely on rxcpp exception handling

d-led · d-led · commit fe8929b4ee34 · 2018-10-21T00:22:04.000+02:00
diff --git a/src/influxdb-cpp-rest/influxdb_simple_async_api.cpp b/src/influxdb-cpp-rest/influxdb_simple_async_api.cpp
@@ -70,7 +70,7 @@ struct influxdb::async_api::simple_db::impl {
                                 try {
                                     db.insert_async(w->str());
                                 } catch (const std::runtime_error& e) {
-                                    std::cerr << "async_api::insert failed: " << e.what() << " -> Dropping " << w->size() << " bytes" << std::endl;
+                                    throw std::runtime_error(std::string("async_api::insert failed: ") + e.what() + " -> Dropping " + std::to_string(w->size()) + " bytes");
                                 }
                             }
                         },

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ struct influxdb::async_api::simple_db::impl {`
`70`	`70`	`try {`
`71`	`71`	`db.insert_async(w->str());`
`72`	`72`	`} catch (const std::runtime_error& e) {`
`73`		`- std::cerr << "async_api::insert failed: " << e.what() << " -> Dropping " << w->size() << " bytes" << std::endl;`
	`73`	`+ throw std::runtime_error(std::string("async_api::insert failed: ") + e.what() + " -> Dropping " + std::to_string(w->size()) + " bytes");`
`74`	`74`	`}`
`75`	`75`	`}`
`76`	`76`	`},`