HomeSort by relevance Sort by last modified time
    Searched refs:subscriber (Results 26 - 50 of 67) sorted by null

12 3

  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-distinct.hpp 44 template<class Subscriber>
47 typedef distinct_observer<Subscriber> this_type;
49 typedef rxu::decay_t<Subscriber> dest_type;
71 static subscriber<value_type, observer<value_type, this_type>> make(dest_type d) {
76 template<class Subscriber>
77 auto operator()(Subscriber dest) const
78 -> decltype(distinct_observer<Subscriber>::make(std::move(dest))) {
79 return distinct_observer<Subscriber>::make(std::move(dest));
rx-element_at.hpp 58 template<class Subscriber>
61 typedef element_at_observer<Subscriber> this_type;
63 typedef rxu::decay_t<Subscriber> dest_type;
89 static subscriber<value_type, observer_type> make(dest_type d, element_at_values v) {
94 template<class Subscriber>
95 auto operator()(Subscriber dest) const
96 -> decltype(element_at_observer<Subscriber>::make(std::move(dest), initial)) {
97 return element_at_observer<Subscriber>::make(std::move(dest), initial);
rx-filter.hpp 53 template<class Subscriber>
56 typedef filter_observer<Subscriber> this_type;
58 typedef rxu::decay_t<Subscriber> dest_type;
89 static subscriber<value_type, observer_type> make(dest_type d, test_type t) {
94 template<class Subscriber>
95 auto operator()(Subscriber dest) const
96 -> decltype(filter_observer<Subscriber>::make(std::move(dest), test)) {
97 return filter_observer<Subscriber>::make(std::move(dest), test);
rx-finally.hpp 57 template<class Subscriber>
60 typedef finally_observer<Subscriber> this_type;
62 typedef rxu::decay_t<Subscriber> dest_type;
80 static subscriber<value_type, observer_type> make(dest_type d, const last_call_type& lc) {
92 template<class Subscriber>
93 auto operator()(Subscriber dest) const
94 -> decltype(finally_observer<Subscriber>::make(std::move(dest), last_call)) {
95 return finally_observer<Subscriber>::make(std::move(dest), last_call);
rx-lift.hpp 7 \brief takes any function that will take a subscriber for this observable and produce a subscriber.
74 template<class Subscriber>
75 void on_subscribe(Subscriber o) const {
94 static_assert(rxcpp::detail::is_lift_function_for<rxu::value_type_t<Observable>, subscriber<ResultType>, Operator>::value, "Function passed for lift() must have the signature subscriber<...>(subscriber<T, ...>)");
rx-pairwise.hpp 47 template<class Subscriber>
50 typedef pairwise_observer<Subscriber> this_type;
52 typedef rxu::decay_t<Subscriber> dest_type;
77 static subscriber<T, observer_type> make(dest_type d) {
83 template<class Subscriber>
84 auto operator()(Subscriber dest) const
85 -> decltype(pairwise_observer<Subscriber>::make(std::move(dest))) {
86 return pairwise_observer<Subscriber>::make(std::move(dest));
rx-skip_while.hpp 54 template<class Subscriber>
57 typedef skip_while_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
85 static subscriber<value_type, observer_type> make(dest_type d, test_type t) {
90 template<class Subscriber>
91 auto operator()(Subscriber dest) const
92 -> decltype(skip_while_observer<Subscriber>::make(std::move(dest), test)) {
93 return skip_while_observer<Subscriber>::make(std::move(dest), test);
rx-take_while.hpp 54 template<class Subscriber>
57 typedef take_while_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
83 static subscriber<value_type, observer_type> make(dest_type d, test_type t) {
88 template<class Subscriber>
89 auto operator()(Subscriber dest) const
90 -> decltype(take_while_observer<Subscriber>::make(std::move(dest), test)) {
91 return take_while_observer<Subscriber>::make(std::move(dest), test);
rx-all.hpp 56 template<class Subscriber>
59 typedef all_observer<Subscriber> this_type;
61 typedef rxu::decay_t<Subscriber> dest_type;
97 static subscriber<value_type, observer_type> make(dest_type d, test_type t) {
102 template<class Subscriber>
103 auto operator()(Subscriber dest) const
104 -> decltype(all_observer<Subscriber>::make(std::move(dest), test)) {
105 return all_observer<Subscriber>::make(std::move(dest), test);
rx-buffer_count.hpp 70 template<class Subscriber>
73 typedef buffer_count_observer<Subscriber> this_type;
75 typedef rxu::decay_t<Subscriber> dest_type;
118 static subscriber<T, observer<T, this_type>> make(dest_type d, buffer_count_values v) {
124 template<class Subscriber>
125 auto operator()(Subscriber dest) const
126 -> decltype(buffer_count_observer<Subscriber>::make(std::move(dest), initial)) {
127 return buffer_count_observer<Subscriber>::make(std::move(dest), initial);
rx-distinct_until_changed.hpp 54 template<class Subscriber>
57 typedef distinct_until_changed_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
84 static subscriber<value_type, observer_type> make(dest_type d, predicate_type p) {
89 template<class Subscriber>
90 auto operator()(Subscriber dest) const
91 -> decltype(distinct_until_changed_observer<Subscriber>::make(std::move(dest), pred)) {
92 return distinct_until_changed_observer<Subscriber>::make(std::move(dest), pred);
rx-map.hpp 54 template<class Subscriber>
57 typedef map_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
87 static subscriber<source_value_type, observer_type> make(dest_type d, select_type s) {
93 template<class Subscriber>
94 auto operator()(Subscriber dest) const
95 -> decltype(map_observer<Subscriber>::make(std::move(dest), selector)) {
96 return map_observer<Subscriber>::make(std::move(dest), selector);
rx-on_error_resume_next.hpp 55 template<class Subscriber>
58 typedef on_error_resume_next_observer<Subscriber> this_type;
62 typedef rxu::decay_t<Subscriber> dest_type;
92 static subscriber<T, observer_type> make(dest_type d, select_type s) {
98 template<class Subscriber>
99 auto operator()(Subscriber dest) const
100 -> decltype(on_error_resume_next_observer<Subscriber>::make(std::move(dest), selector)) {
101 return on_error_resume_next_observer<Subscriber>::make(std::move(dest), selector);
rx-switch_if_empty.hpp 54 template<class Subscriber>
57 typedef switch_if_empty_observer<Subscriber> this_type;
59 typedef rxu::decay_t<Subscriber> dest_type;
90 static subscriber<value_type, observer_type> make(dest_type d, backup_source_type b) {
96 template<class Subscriber>
97 auto operator()(Subscriber dest) const
98 -> decltype(switch_if_empty_observer<Subscriber>::make(std::move(dest), std::move(backup))) {
99 return switch_if_empty_observer<Subscriber>::make(std::move(dest), std::move(backup));
rx-tap.hpp 13 \return Observable that emits the same items as the source observable to both the subscriber and the observer.
74 template<class Subscriber>
77 using this_type = tap_observer<Subscriber>;
79 using dest_type = rxu::decay_t<Subscriber>;
104 static subscriber<value_type, observer<value_type, this_type>> make(dest_type d, out_type o) {
109 template<class Subscriber>
110 auto operator()(Subscriber dest) const
111 -> decltype(tap_observer<Subscriber>::make(std::move(dest), out)) {
112 return tap_observer<Subscriber>::make(std::move(dest), out);
rx-time_interval.hpp 63 template<class Subscriber>
66 typedef time_interval_observer<Subscriber> this_type;
68 typedef rxu::decay_t<Subscriber> dest_type;
94 static subscriber<value_type, observer_type> make(dest_type d, time_interval_values v) {
99 template<class Subscriber>
100 auto operator()(Subscriber dest) const
101 -> decltype(time_interval_observer<Subscriber>::make(std::move(dest), initial)) {
102 return time_interval_observer<Subscriber>::make(std::move(dest), initial);
rx-timestamp.hpp 62 template<class Subscriber>
65 typedef timestamp_observer<Subscriber> this_type;
67 typedef rxu::decay_t<Subscriber> dest_type;
88 static subscriber<value_type, observer_type> make(dest_type d, timestamp_values v) {
93 template<class Subscriber>
94 auto operator()(Subscriber dest) const
95 -> decltype(timestamp_observer<Subscriber>::make(std::move(dest), initial)) {
96 return timestamp_observer<Subscriber>::make(std::move(dest), initial);
rx-window.hpp 70 template<class Subscriber>
73 typedef window_observer<Subscriber> this_type;
75 typedef rxu::decay_t<Subscriber> dest_type;
120 static subscriber<T, observer_type> make(dest_type d, window_values v) {
126 template<class Subscriber>
127 auto operator()(Subscriber dest) const
128 -> decltype(window_observer<Subscriber>::make(std::move(dest), initial)) {
129 return window_observer<Subscriber>::make(std::move(dest), initial);
rx-any.hpp 63 template<class Subscriber>
66 typedef any_observer<Subscriber> this_type;
68 typedef rxu::decay_t<Subscriber> dest_type;
104 static subscriber<value_type, observer_type> make(dest_type d, test_type t) {
109 template<class Subscriber>
110 auto operator()(Subscriber dest) const
111 -> decltype(any_observer<Subscriber>::make(std::move(dest), test)) {
112 return any_observer<Subscriber>::make(std::move(dest), test);
rx-buffer_time_count.hpp 76 template<class Subscriber>
79 typedef buffer_with_time_or_count_observer<Subscriber> this_type;
81 typedef rxu::decay_t<Subscriber> dest_type;
210 static subscriber<T, observer<T, this_type>> make(dest_type d, buffer_with_time_or_count_values v) {
218 template<class Subscriber>
219 auto operator()(Subscriber dest) const
220 -> decltype(buffer_with_time_or_count_observer<Subscriber>::make(std::move(dest), initial)) {
221 return buffer_with_time_or_count_observer<Subscriber>::make(std::move(dest), initial);
rx-debounce.hpp 69 template<class Subscriber>
72 typedef debounce_observer<Subscriber> this_type;
74 typedef rxu::decay_t<Subscriber> dest_type;
193 static subscriber<T, observer_type> make(dest_type d, debounce_values v) {
201 template<class Subscriber>
202 auto operator()(Subscriber dest) const
203 -> decltype(debounce_observer<Subscriber>::make(std::move(dest), initial)) {
204 return debounce_observer<Subscriber>::make(std::move(dest), initial);
rx-delay.hpp 68 template<class Subscriber>
71 typedef delay_observer<Subscriber> this_type;
73 typedef rxu::decay_t<Subscriber> dest_type;
162 static subscriber<T, observer_type> make(dest_type d, delay_values v) {
170 template<class Subscriber>
171 auto operator()(Subscriber dest) const
172 -> decltype(delay_observer<Subscriber>::make(std::move(dest), initial)) {
173 return delay_observer<Subscriber>::make(std::move(dest), initial);
  /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
lift.cpp 16 template<class Subscriber>
17 struct filter_observer : public rx::observer_base<typename std::decay<Subscriber>::type::value_type>
19 typedef filter_observer<Subscriber> this_type;
20 typedef rx::observer_base<typename std::decay<Subscriber>::type::value_type> base_type;
22 typedef typename std::decay<Subscriber>::type dest_type;
51 static rx::subscriber<value_type, observer_type> make(const dest_type& d, const test_type& t) {
56 template<class Subscriber>
57 auto operator()(const Subscriber& dest) const
58 -> decltype(filter_observer<Subscriber>::make(dest, test)) {
59 return filter_observer<Subscriber>::make(dest, test)
    [all...]
  /cts/hostsidetests/statsd/src/android/cts/statsd/subscriber/
ShellSubscriberTest.java 16 package android.cts.statsd.subscriber;
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-observable.hpp 20 template<class Subscriber, class T>
29 typedef decltype(check<rxu::decay_t<Subscriber>, T>(0)) detail_result;
42 typedef std::function<void(subscriber<T>)> onsubscribe_type;
54 state->on_subscribe = [so](subscriber<T> o) mutable {
81 void on_subscribe(subscriber<T> o) const {
85 template<class Subscriber>
86 typename std::enable_if<is_subscriber<Subscriber>::value, void>::type
87 on_subscribe(Subscriber o) const {
223 /// `subscribe` will cause this observable to emit values to the provided subscriber.
229 /// callers must provide enough arguments to make a subscriber
519 sc.create_worker(o.get_subscription()).schedule(subscriber); variable
    [all...]

Completed in 4416 milliseconds

12 3