Home
last modified time | relevance | path

Searched refs:SourceOperator (Results 1 – 5 of 5) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-connectable_observable.hpp104 template<class T, class SourceOperator>
106 : public observable<T, SourceOperator>
108 typedef connectable_observable<T, SourceOperator> this_type;
109 typedef observable<T, SourceOperator> base_type;
110 typedef rxu::decay_t<SourceOperator> source_operator_type;
121 explicit connectable_observable(const SourceOperator& o) in connectable_observable()
125 explicit connectable_observable(SourceOperator&& o) in connectable_observable()
195 template<class T, class SourceOperator, class OperatorFactory>
196 auto operator >> (const rxcpp::connectable_observable<T, SourceOperator>& source, OperatorFactory&&… in operator >>()
205 template<class T, class SourceOperator, class OperatorFactory>
[all …]
Drx-grouped_observable.hpp120 template<class K, class T, class SourceOperator>
122 : public observable<T, SourceOperator>
124 typedef grouped_observable<K, T, SourceOperator> this_type;
125 typedef observable<T, SourceOperator> base_type;
126 typedef rxu::decay_t<SourceOperator> source_operator_type;
138 explicit grouped_observable(const SourceOperator& o) in grouped_observable()
142 explicit grouped_observable(SourceOperator&& o) in grouped_observable()
177 template<class K, class T, class SourceOperator, class OperatorFactory>
178 auto operator >> (const rxcpp::grouped_observable<K, T, SourceOperator>& source, OperatorFactory&& … in operator >>()
187 template<class K, class T, class SourceOperator, class OperatorFactory>
[all …]
Drx-coroutine.hpp182 template<typename T, typename SourceOperator>
183 auto begin(const rxcpp::observable<T, SourceOperator>& o) in begin()
184 -> rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>> { in begin()
185 … return rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>>{o}; in begin()
188 template<typename T, typename SourceOperator>
189 auto end(const rxcpp::observable<T, SourceOperator>&) in end() argument
190 -> rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>> { in end()
191 return rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>>{}; in end()
Drx-observable.hpp432 template<class SourceOperator, class Subscriber>
435 …safe_subscriber(SourceOperator& so, Subscriber& o) : so(std::addressof(so)), o(std::addressof(o)) … in safe_subscriber()
453 SourceOperator* so;
481 template<class T, class SourceOperator>
485 …static_assert(std::is_same<T, typename SourceOperator::value_type>::value, "SourceOperator::value_…
487 typedef observable<T, SourceOperator> this_type;
490 typedef rxu::decay_t<SourceOperator> source_operator_type;
1469 template<class T, class SourceOperator>
1470 inline bool operator==(const observable<T, SourceOperator>& lhs, const observable<T, SourceOperator… in operator ==()
1473 template<class T, class SourceOperator>
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-lift.hpp50 template<class ResultType, class SourceOperator, class Operator>
54 typedef rxu::decay_t<SourceOperator> source_operator_type;
60 template<class ResultType, class SourceOperator, class Operator>
61 struct lift_operator : public operator_base<typename lift_traits<ResultType, SourceOperator, Operat…
63 typedef lift_traits<ResultType, SourceOperator, Operator> traits;