| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-notification.hpp | 49 typedef subscriber<T> observer_type; typedef
56 virtual void accept(const observer_type& o) const =0;
119 typedef typename detail::notification_base<T>::observer_type observer_type; typedef
142 virtual void accept(const typename base::observer_type& o) const { in accept()
167 virtual void accept(const typename base::observer_type& o) const { in accept()
186 virtual void accept(const typename base::observer_type& o) const { in accept()
|
| D | rx-coordination.hpp | 214 typedef observer<value_type, this_type> observer_type; typedef
240 …static subscriber<value_type, observer_type> make(const Subscriber& s, std::shared_ptr<std::mutex>… in make()
241 … return make_subscriber<value_type>(s, observer_type(this_type(s.get_observer(), std::move(m)))); in make()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-pairwise.hpp | 53 typedef observer<T, this_type> observer_type; typedef
77 static subscriber<T, observer_type> make(dest_type d) { in make()
79 return make_subscriber<T>(std::move(cs), observer_type(this_type(std::move(d)))); in make()
|
| D | rx-map.hpp | 60 typedef observer<source_value_type, this_type> observer_type; typedef
87 static subscriber<source_value_type, observer_type> make(dest_type d, select_type s) { in make()
89 …return make_subscriber<source_value_type>(std::move(cs), observer_type(this_type(std::move(d), std… in make()
|
| D | rx-on_error_resume_next.hpp | 63 typedef observer<T, this_type> observer_type; typedef
92 static subscriber<T, observer_type> make(dest_type d, select_type s) { in make()
94 return make_subscriber<T>(cs, observer_type(this_type(std::move(d), cs, std::move(s)))); in make()
|
| D | rx-window.hpp | 76 typedef observer<T, this_type> observer_type; typedef
120 static subscriber<T, observer_type> make(dest_type d, window_values v) { in make()
122 … return make_subscriber<T>(std::move(cs), observer_type(this_type(std::move(d), std::move(v)))); in make()
|
| D | rx-switch_if_empty.hpp | 60 typedef observer<value_type, this_type> observer_type; typedef
90 static subscriber<value_type, observer_type> make(dest_type d, backup_source_type b) { in make()
92 … return make_subscriber<value_type>(cs, observer_type(this_type(std::move(d), cs, std::move(b)))); in make()
|
| D | rx-ignore_elements.hpp | 47 typedef observer<value_type, this_type> observer_type; typedef
67 static subscriber<value_type, observer_type> make(dest_type d) { in make()
|
| D | rx-take_while.hpp | 60 typedef observer<value_type, this_type> observer_type; typedef
83 static subscriber<value_type, observer_type> make(dest_type d, test_type t) { in make()
|
| D | rx-finally.hpp | 63 typedef observer<value_type, this_type> observer_type; typedef
80 static subscriber<value_type, observer_type> make(dest_type d, const last_call_type& lc) { in make()
|
| D | rx-skip_while.hpp | 60 typedef observer<value_type, this_type> observer_type; typedef
85 static subscriber<value_type, observer_type> make(dest_type d, test_type t) { in make()
|
| D | rx-element_at.hpp | 64 typedef observer<value_type, this_type> observer_type; typedef
89 static subscriber<value_type, observer_type> make(dest_type d, element_at_values v) { in make()
|
| D | rx-filter.hpp | 59 typedef observer<value_type, this_type> observer_type; typedef
89 static subscriber<value_type, observer_type> make(dest_type d, test_type t) { in make()
|
| D | rx-distinct_until_changed.hpp | 60 typedef observer<value_type, this_type> observer_type; typedef
84 static subscriber<value_type, observer_type> make(dest_type d, predicate_type p) { in make()
|
| D | rx-time_interval.hpp | 69 typedef observer<value_type, this_type> observer_type; typedef
94 static subscriber<value_type, observer_type> make(dest_type d, time_interval_values v) { in make()
|
| D | rx-timestamp.hpp | 68 typedef observer<value_type, this_type> observer_type; typedef
88 static subscriber<value_type, observer_type> make(dest_type d, timestamp_values v) { in make()
|
| D | rx-all.hpp | 62 typedef observer<value_type, this_type> observer_type; typedef
97 static subscriber<value_type, observer_type> make(dest_type d, test_type t) { in make()
|
| D | rx-delay.hpp | 74 typedef observer<T, this_type> observer_type; typedef
162 static subscriber<T, observer_type> make(dest_type d, delay_values v) { in make()
166 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
|
| D | rx-any.hpp | 69 typedef observer<value_type, this_type> observer_type; typedef
104 static subscriber<value_type, observer_type> make(dest_type d, test_type t) { in make()
|
| D | rx-timeout.hpp | 83 typedef observer<T, this_type> observer_type; typedef
209 static subscriber<T, observer_type> make(dest_type d, timeout_values v) { in make()
213 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
|
| D | rx-window_time_count.hpp | 82 typedef observer<T, this_type> observer_type; typedef
216 static subscriber<T, observer_type> make(dest_type d, window_with_time_or_count_values v) { in make()
220 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
|
| D | rx-debounce.hpp | 75 typedef observer<T, this_type> observer_type; typedef
193 static subscriber<T, observer_type> make(dest_type d, debounce_values v) { in make()
197 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
|
| D | rx-window_toggle.hpp | 88 typedef observer<T, this_type> observer_type; typedef
255 static subscriber<T, observer_type> make(dest_type d, window_toggle_values v) { in make()
259 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 19 typedef subscriber<T> observer_type; typedef in rxcpp::subjects::detail::multicast_observer
20 typedef std::vector<observer_type> list_type;
53 …er_type(std::shared_ptr<state_type> s, const std::shared_ptr<completer_type>& old, observer_type o) in completer_type()
70 [](const observer_type& o){ in retain()
132 void add(const SubscriberFrom& sf, observer_type o) const { in add()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | lift.cpp | 23 typedef rx::observer<value_type, this_type> observer_type; typedef
51 … static rx::subscriber<value_type, observer_type> make(const dest_type& d, const test_type& t) { in make()
52 return rx::make_subscriber<value_type>(d, observer_type(this_type(d, t))); in make()
|