Searched refs:observable_type (Results 1 – 5 of 5) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ref_count.hpp | 53 template <typename connectable_type, typename observable_type>
55 ref_count_state_base(connectable_type other, observable_type source) in ref_count_state_base()
60 observable_type subscribable; // subscribes to this if non-empty.
87 typedef rxu::decay_t<Observable> observable_type; typedef
109 typename std::enable_if<HasObservableV, observable_type>::type source) in ref_count_state()
141 typename std::enable_if<HasObservableV, observable_type>::type source) in ref_count()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-interval.hpp | 116 typename detail::defer_interval<Duration, identity_one_worker>::observable_type>::type { in interval()
126 …tail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::observable_type>::type { in interval()
136 typename detail::defer_interval<Duration, identity_one_worker>::observable_type>::type { in interval()
146 …tail::defer_interval<rxsc::scheduler::clock_type::duration, Coordination>::observable_type>::type { in interval()
|
| D | rx-timer.hpp | 117 …typename detail::defer_timer<TimePointOrDuration, identity_one_worker>::observable_type>::type { in timer()
127 typename detail::defer_timer<TimePointOrDuration, Coordination>::observable_type>::type { in timer()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 116 typedef observable<value_type, type> observable_type; typedef
118 static observable_type make(const Default&, AN&&... an) { in make()
119 return observable_type(type(std::forward<AN>(an)...)); in make()
126 typedef Default observable_type; typedef
128 static observable_type make(const observable_type& that, const AN&...) { in make()
138 typedef observable<value_type, type> observable_type; typedef
140 static observable_type make(AN&&... an) { in make()
141 return observable_type(type(std::forward<AN>(an)...)); in make()
148 typedef void observable_type; typedef
150 static observable_type make(const AN&...) { in make()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 243 typedef observable<T> observable_type; typedef in rxcpp::subjects::subject
|