| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observer.hpp | 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
371 virtual void on_next(T&& t) const { in on_next() function
437 void on_next(V&& v) const { in on_next() function in rxcpp::observer
|
| /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
|
| D | rx-synchronize.hpp | 105 void on_next(V v) const { in on_next() function
150 void on_next(V v) const { in on_next() function in rxcpp::subjects::detail::synchronize_observer
|
| D | rx-replaysubject.hpp | 119 void on_next(V v) const { in on_next() function in rxcpp::subjects::detail::replay_observer
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-ignore_elements.hpp | 55 void on_next(source_value_type) const { in on_next() function
|
| D | rx-distinct.hpp | 58 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-pairwise.hpp | 61 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-take_while.hpp | 69 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-skip_while.hpp | 71 void on_next(source_value_type v) { in on_next() function
|
| D | rx-finally.hpp | 70 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-filter.hpp | 70 void on_next(Value&& v) const { in on_next() function
|
| D | rx-distinct_until_changed.hpp | 71 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-element_at.hpp | 74 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-map.hpp | 70 void on_next(Value&& v) const { in on_next() function
|
| D | rx-timestamp.hpp | 78 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-switch_if_empty.hpp | 75 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-buffer_count.hpp | 87 void on_next(T v) const { in on_next() function
|
| D | rx-time_interval.hpp | 82 void on_next(source_value_type) const { in on_next() function
|
| D | rx-on_error_resume_next.hpp | 75 void on_next(value_type v) const { in on_next() function
|
| D | rx-tap.hpp | 91 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-all.hpp | 73 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-any.hpp | 80 void on_next(source_value_type v) const { in on_next() function
|
| D | rx-window.hpp | 89 void on_next(T v) const { in on_next() function
|
| /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
113 ready on_next(T v) { in on_next() function in asyncwithready::async_subscriber
188 std::future<unit> on_next(T v) { in on_next() function in asyncwithfuture::async_subscriber
|
| /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
|