summaryrefslogtreecommitdiff
path: root/Rx/v2/src/rxcpp/operators/rx-concat.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'Rx/v2/src/rxcpp/operators/rx-concat.hpp')
-rw-r--r--Rx/v2/src/rxcpp/operators/rx-concat.hpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/Rx/v2/src/rxcpp/operators/rx-concat.hpp b/Rx/v2/src/rxcpp/operators/rx-concat.hpp
index 2afe974..01f023d 100644
--- a/Rx/v2/src/rxcpp/operators/rx-concat.hpp
+++ b/Rx/v2/src/rxcpp/operators/rx-concat.hpp
@@ -15,13 +15,13 @@ namespace detail {
template<class T, class Observable, class Coordination>
struct concat
- : public operator_base<typename std::decay<T>::type::value_type>
+ : public operator_base<rxu::value_type_t<rxu::decay_t<T>>>
{
typedef concat<T, Observable, Coordination> this_type;
- typedef typename std::decay<T>::type source_value_type;
- typedef typename std::decay<Observable>::type source_type;
- typedef typename std::decay<Coordination>::type coordination_type;
+ typedef rxu::decay_t<T> source_value_type;
+ typedef rxu::decay_t<Observable> source_type;
+ typedef rxu::decay_t<Coordination> coordination_type;
typedef typename coordination_type::coordinator_type coordinator_type;
@@ -184,7 +184,7 @@ struct concat
template<class Coordination>
class concat_factory
{
- typedef typename std::decay<Coordination>::type coordination_type;
+ typedef rxu::decay_t<Coordination> coordination_type;
coordination_type coordination;
public:
@@ -195,9 +195,9 @@ public:
template<class Observable>
auto operator()(Observable source)
- -> observable<typename concat<typename Observable::value_type, Observable, Coordination>::value_type, concat<typename Observable::value_type, Observable, Coordination>> {
- return observable<typename concat<typename Observable::value_type, Observable, Coordination>::value_type, concat<typename Observable::value_type, Observable, Coordination>>(
- concat<typename Observable::value_type, Observable, Coordination>(std::move(source), coordination));
+ -> observable<rxu::value_type_t<concat<rxu::value_type_t<Observable>, Observable, Coordination>>, concat<rxu::value_type_t<Observable>, Observable, Coordination>> {
+ return observable<rxu::value_type_t<concat<rxu::value_type_t<Observable>, Observable, Coordination>>, concat<rxu::value_type_t<Observable>, Observable, Coordination>>(
+ concat<rxu::value_type_t<Observable>, Observable, Coordination>(std::move(source), coordination));
}
};