summaryrefslogtreecommitdiff
path: root/Rx/v2/examples
diff options
context:
space:
mode:
authorValery Kopylov <v-valkop@microsoft.com>2015-06-09 15:19:53 +0300
committerValery Kopylov <v-valkop@microsoft.com>2015-06-09 15:19:53 +0300
commit2482b20a4a2d631b61002497af8ce72aacc842a2 (patch)
treeecf7741c811f396a47106982d91becb283802378 /Rx/v2/examples
parentcffd1189771d80e7dd244701bf76819cadf17758 (diff)
downloadRxCpp-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.cpp3
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();