| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | create.cpp | 18 s.on_next(1); in __anon527a49e30102()
19 s.on_next(2); in __anon527a49e30102()
60 o.on_next(v + 1); in __anon527a49e30302()
62 sn.on_next(1); in __anon527a49e30302()
63 sn.on_next(2); in __anon527a49e30302()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 10 s.on_next(1); in __anonfb3350bc0102()
11 s.on_next(2); in __anonfb3350bc0102()
38 s.on_next(i); in __anonfb3350bc0602()
65 s.on_next(i); in __anonfb3350bc0902()
81 s.on_next(i); in __anonfb3350bc0a02()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | observer.cpp | 42 scrbResult.on_next(1);
128 dob.on_next(1);
132 so.on_next(1);
136 dob.on_next(1);
140 so.on_next(1);
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observer.hpp | 64 s.on_next(t); in operator ()()
67 s.on_next(t); in operator ()()
241 void on_next(T& t) const { in on_next() function in rxcpp::observer
244 void on_next(T&& t) const { in on_next() function in rxcpp::observer
329 void on_next(T& t) const { in on_next() function in rxcpp::observer
332 void on_next(T&& t) const { in on_next() function in rxcpp::observer
353 virtual void on_next(T&) const {}; in on_next() function
354 virtual void on_next(T&&) const {}; in on_next() function
368 virtual void on_next(T& t) const { in on_next() function
369 destination.on_next(t); in on_next()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window.hpp | 87 dest.on_next(subj[0].get_observable().as_dynamic()); in window_observer()
89 void on_next(T v) const { in on_next() function
91 s.get_subscriber().on_next(v); in on_next()
102 dest.on_next(subj[subj.size() - 1].get_observable().as_dynamic()); in on_next()
|
| D | rx-tap.hpp | 91 void on_next(source_value_type v) const { in on_next() function
92 out.on_next(v); in on_next()
93 dest.on_next(v); in on_next()
|
| D | rx-all.hpp | 73 void on_next(source_value_type v) const { in on_next() function
82 dest.on_next(false); in on_next()
92 dest.on_next(true); in on_completed()
|
| D | rx-buffer_count.hpp | 87 void on_next(T v) const { in on_next() function
95 dest.on_next(std::move(chunks.front())); in on_next()
106 dest.on_next(std::move(chunks.front())); in on_completed()
|
| D | rx-any.hpp | 80 void on_next(source_value_type v) const { in on_next() function
89 dest.on_next(true); in on_next()
99 dest.on_next(false); in on_completed()
|
| D | rx-distinct.hpp | 58 void on_next(source_value_type v) const { in on_next() function
61 dest.on_next(v); in on_next()
|
| D | rx-finally.hpp | 70 void on_next(source_value_type v) const { in on_next() function
71 dest.on_next(v); in on_next()
|
| D | rx-pairwise.hpp | 61 void on_next(source_value_type v) const { in on_next() function
67 dest.on_next(std::make_tuple(remembered.get(), v)); in on_next()
|
| D | rx-take_while.hpp | 69 void on_next(source_value_type v) const { in on_next() function
71 dest.on_next(v); in on_next()
|
| D | rx-element_at.hpp | 74 void on_next(source_value_type v) const { in on_next() function
76 dest.on_next(v); in on_next()
|
| D | rx-skip_while.hpp | 71 void on_next(source_value_type v) { in on_next() function
75 dest.on_next(v); in on_next()
|
| D | rx-filter.hpp | 70 void on_next(Value&& v) const { in on_next() function
79 dest.on_next(std::forward<Value>(v)); in on_next()
|
| D | rx-distinct_until_changed.hpp | 71 void on_next(source_value_type v) const { in on_next() function
74 dest.on_next(v); in on_next()
|
| D | rx-skip_last.hpp | 97 state->out.on_next(std::move(state->items.front())); in on_subscribe()
102 state->out.on_next(t); in on_subscribe()
|
| D | rx-take.hpp | 104 state->out.on_next(t); in on_subscribe()
107 state->out.on_next(t); in on_subscribe()
|
| D | rx-map.hpp | 70 void on_next(Value&& v) const { in on_next() function
78 dest.on_next(std::move(selected.get())); in on_next()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-behavior.hpp | 61 void on_next(V v) const { in on_next() function in rxcpp::subjects::detail::behavior_observer
63 base_type::on_next(std::move(v)); in on_next()
96 o.on_next(get_value()); in get_observable()
|
| D | rx-synchronize.hpp | 105 void on_next(V v) const { in on_next() function
108 fill_queue.push_back(notification_type::on_next(std::move(v))); in on_next()
150 void on_next(V v) const { in on_next() function in rxcpp::subjects::detail::synchronize_observer
151 state->on_next(std::move(v)); in on_next()
|
| D | rx-replaysubject.hpp | 119 void on_next(V v) const { in on_next() function in rxcpp::subjects::detail::replay_observer
121 base_type::on_next(std::move(v)); in on_next()
174 o.on_next(value); in get_observable()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 50 void on_next(T v) { in on_next() function in syncwithvoid::sync_subscriber
69 scbr.on_next(i);
113 ready on_next(T v) { in on_next() function in asyncwithready::async_subscriber
157 auto controller = scbr.on_next(i); in __anon6a6aec1e0402()
188 std::future<unit> on_next(T v) { in on_next() function in asyncwithfuture::async_subscriber
208 auto isready = scbr.on_next(i);
237 o.on_next(i);
263 o.on_next(i);
358 o.on_next(i);
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | lift.cpp | 32 void on_next(typename dest_type::value_type v) const { in on_next() function
41 dest.on_next(v); in on_next()
252 if (pass) {dest.on_next(n);} in __anon3f4dc8d90602()
|