summaryrefslogtreecommitdiff
path: root/Rx
diff options
context:
space:
mode:
authorMichael Maier <maiermic@users.noreply.github.com>2017-04-27 01:06:19 +0200
committerKirk Shoop <kirk.shoop@microsoft.com>2017-04-26 16:06:19 -0700
commit18e8de22bbea8e295a80d9398599d50aa3e5be53 (patch)
treeba9a3d38df90ab3269718b7092c69230c533ec47 /Rx
parentb41b15f1daf97519433742ff86adad9d0ae8acdd (diff)
downloadRxCpp-18e8de22bbea8e295a80d9398599d50aa3e5be53.tar.gz
subscribe in reverse order to observables (#375)
Diffstat (limited to 'Rx')
-rw-r--r--Rx/v2/src/rxcpp/operators/rx-with_latest_from.hpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/Rx/v2/src/rxcpp/operators/rx-with_latest_from.hpp b/Rx/v2/src/rxcpp/operators/rx-with_latest_from.hpp
index bce0596..febba99 100644
--- a/Rx/v2/src/rxcpp/operators/rx-with_latest_from.hpp
+++ b/Rx/v2/src/rxcpp/operators/rx-with_latest_from.hpp
@@ -193,7 +193,7 @@ struct with_latest_from : public operator_base<rxu::value_type_t<with_latest_fro
}
template<class State, int... IndexN>
void subscribe_all(std::shared_ptr<State> state, rxu::values<int, IndexN...>) const {
- bool subscribed[] = {(subscribe_one<IndexN>(state), true)...};
+ bool subscribed[] = {(subscribe_one<(sizeof...(IndexN)) - 1 - IndexN>(state), true)...};
subscribed[0] = (*subscribed); // silence warning
}