HomeSort by relevance Sort by last modified time
    Searched refs:Subscriber (Results 1 - 25 of 75) sorted by null

1 2 3

  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-trace.hpp 60 template<class Observable, class Subscriber>
61 inline void subscribe_enter(const Observable& , const Subscriber& ) {}
68 template<class OperatorSource, class OperatorChain, class Subscriber, class SubscriberLifted>
69 inline void lift_enter(const OperatorSource&, const OperatorChain&, const Subscriber&, const SubscriberLifted&) {}
88 template<class Subscriber>
89 inline void create_subscriber(const Subscriber&) {}
91 template<class Subscriber, class T>
92 inline void on_next_enter(const Subscriber&, const T&) {}
93 template<class Subscriber>
94 inline void on_next_return(const Subscriber&) {
    [all...]
rx-coordination.hpp 59 template<class Subscriber>
62 typedef decltype((*(input_type*)nullptr).out((*(Subscriber*)nullptr))) type;
99 template<class Subscriber>
100 auto out(Subscriber s) const
101 -> typename get_subscriber<Subscriber>::type {
103 static_assert(is_subscriber<Subscriber>::value, "can only synchronize subscribers");
142 template<class Subscriber>
143 auto out(Subscriber s) const
144 -> Subscriber {
239 template<class Subscriber>
    [all...]
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
rx-never.hpp 32 template<class Subscriber>
33 void on_subscribe(Subscriber) const {
rx-create.hpp 12 \brief Returns an observable that executes the specified function when a subscriber subscribes to it.
19 \return Observable that executes the specified function when a Subscriber subscribes to it.
65 template<class Subscriber>
66 void on_subscribe(Subscriber o) const {
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-ignore_elements.hpp 41 template<class Subscriber>
44 typedef ignore_elements_observer<Subscriber> this_type;
46 typedef rxu::decay_t<Subscriber> dest_type;
67 static subscriber<value_type, observer_type> make(dest_type d) {
72 template<class Subscriber>
73 auto operator()(Subscriber dest) const
74 -> decltype(ignore_elements_observer<Subscriber>::make(std::move(dest))) {
75 return ignore_elements_observer<Subscriber>::make(std::move(dest));
rx-retry-repeat-common.hpp 17 template <class Values, class Subscriber, class EventHandlers, class T>
18 struct state_type : public std::enable_shared_from_this<state_type<Values, Subscriber, EventHandlers, T>>,
21 typedef Subscriber output_type;
93 template<class Subscriber>
94 void on_subscribe(const Subscriber& s) const {
95 typedef state_type<values, Subscriber, EventHandlers, T> state_t;
136 template<class Subscriber>
137 void on_subscribe(const Subscriber& s) const {
138 typedef state_type<values, Subscriber, EventHandlers, T> state_t;
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-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-connect_forever.hpp 47 template<class Subscriber>
48 void on_subscribe(Subscriber&& o) const {
49 source.subscribe(std::forward<Subscriber>(o));
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-ref_count.hpp 62 template <typename Subscriber>
63 void subscribe(Subscriber&& o) {
64 subscribable.subscribe(std::forward<Subscriber>(o));
76 template <typename Subscriber>
77 void subscribe(Subscriber&& o) {
78 connectable.subscribe(std::forward<Subscriber>(o));
146 template<class Subscriber>
147 void on_subscribe(Subscriber&& o) const {
160 keepAlive->subscribe(std::forward<Subscriber>(o));

Completed in 6498 milliseconds

1 2 3