diff options
| author | Valery Kopylov <v-valkop@microsoft.com> | 2015-06-02 15:17:20 +0300 |
|---|---|---|
| committer | Valery Kopylov <v-valkop@microsoft.com> | 2015-06-09 13:00:54 +0300 |
| commit | a9a4aea066ed833a569559d3662dca82af4d9a32 (patch) | |
| tree | c6d57808cece5ce496650dde3d92d685755a4bc0 /Rx | |
| parent | a217bbaeee8d5641cb10dbfdc253cb93d6eb7ba7 (diff) | |
| download | RxCpp-a9a4aea066ed833a569559d3662dca82af4d9a32.tar.gz | |
Remove duplicating code from blocking_observable.
Diffstat (limited to 'Rx')
| -rw-r--r-- | Rx/v2/src/rxcpp/rx-observable.hpp | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/Rx/v2/src/rxcpp/rx-observable.hpp b/Rx/v2/src/rxcpp/rx-observable.hpp index 5ed5ec0..ffe7450 100644 --- a/Rx/v2/src/rxcpp/rx-observable.hpp +++ b/Rx/v2/src/rxcpp/rx-observable.hpp @@ -278,11 +278,7 @@ public: } T first() { - rxu::maybe<T> result; - composite_subscription cs; - subscribe(cs, [&](T v){result.reset(v); cs.unsubscribe();}); - if (result.empty()) throw std::runtime_error("No elements"); - return result.get(); + return source.first().as_blocking().last(); } T last() const { |