Searched refs:source_operator (Results 1 – 8 of 8) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-switch_on_next.hpp | 64 : source_operator(std::move(o)) in values()
68 source_operator_type source_operator; member
74 : initial(o.source_operator, std::move(sf)) in switch_on_next()
90 , source(i.source_operator) in on_subscribe()
|
| D | rx-merge.hpp | 85 : source_operator(std::move(o)) in values()
89 source_operator_type source_operator; member
95 : initial(o.source_operator, std::move(sf)) in merge()
111 , source(i.source_operator) in on_subscribe()
|
| D | rx-merge_delay_error.hpp | 78 : source_operator(std::move(o)) in values()
82 source_operator_type source_operator; member
88 : initial(o.source_operator, std::move(sf)) in merge_delay_error()
104 , source(i.source_operator) in on_subscribe()
|
| D | rx-amb.hpp | 81 : source_operator(std::move(o)) in values()
85 source_operator_type source_operator; member
91 : initial(o.source_operator, std::move(sf)) in amb()
107 , source(i.source_operator) in on_subscribe()
|
| D | rx-concat.hpp | 81 : source_operator(std::move(o)) in values()
85 source_operator_type source_operator; member
91 : initial(o.source_operator, std::move(sf)) in concat()
107 , source(i.source_operator) in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 491 mutable source_operator_type source_operator; member in rxcpp::observable
518 … detail::safe_subscriber<source_operator_type, subscriber_type> subscriber(source_operator, o); in detail_subscribe()
547 : source_operator(o) in observable()
551 : source_operator(std::move(o)) in observable()
558 : source_operator(o.source_operator) in observable()
563 : source_operator(std::move(o.source_operator)) in observable()
569 source_operator.on_subscribe(o);
620 …o::detail::lift_operator<ResultType, source_operator_type, Operator>(source_operator, std::forward… in lift()
634 …o::detail::lift_operator<ResultType, source_operator_type, Operator>(source_operator, std::forward… in lift_if()
1471 return lhs.source_operator == rhs.source_operator; in operator ==()
|
| D | rx-connectable_observable.hpp | 161 base_type::source_operator.on_connect(cs); in connect()
|
| D | rx-grouped_observable.hpp | 166 return base_type::source_operator.on_get_key(); in get_key()
|