diff options
author | Valery Kopylov <v-valkop@microsoft.com> | 2015-06-09 15:19:53 +0300 |
---|---|---|
committer | Valery Kopylov <v-valkop@microsoft.com> | 2015-06-09 15:19:53 +0300 |
commit | 2482b20a4a2d631b61002497af8ce72aacc842a2 (patch) | |
tree | ecf7741c811f396a47106982d91becb283802378 /Rx/v2/examples | |
parent | cffd1189771d80e7dd244701bf76819cadf17758 (diff) | |
download | RxCpp-2482b20a4a2d631b61002497af8ce72aacc842a2.tar.gz |
Use subscribe_with_rethrow for blocking first and last.
Diffstat (limited to 'Rx/v2/examples')
-rw-r--r-- | Rx/v2/examples/doxygen/blocking_observable.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/Rx/v2/examples/doxygen/blocking_observable.cpp b/Rx/v2/examples/doxygen/blocking_observable.cpp index ee94013..1e7dd56 100644 --- a/Rx/v2/examples/doxygen/blocking_observable.cpp +++ b/Rx/v2/examples/doxygen/blocking_observable.cpp @@ -25,8 +25,7 @@ SCENARIO("blocking first empty sample"){ SCENARIO("blocking first error sample"){ printf("//! [blocking first error sample]\n"); - auto values = rxcpp::observable<>::range(1, 3). - concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))). + auto values = rxcpp::observable<>::error<int>(std::runtime_error("Error from source")). as_blocking(); try { auto first = values.first(); |