HomeSort by relevance Sort by last modified time
    Searched defs:on_next (Results 1 - 25 of 41) sorted by null

1 2

  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-tap.hpp 7 \brief inspect calls to on_next, on_error and on_completed.
91 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::tap::tap_observer
92 out.on_next(v);
93 dest.on_next(v);
rx-all.hpp 73 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::all::all_observer
82 dest.on_next(false);
92 dest.on_next(true);
rx-any.hpp 80 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::any::any_observer
89 dest.on_next(true);
99 dest.on_next(false);
rx-distinct.hpp 58 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::distinct::distinct_observer
61 dest.on_next(v);
rx-distinct_until_changed.hpp 71 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::distinct_until_changed::distinct_until_changed_observer
74 dest.on_next(v);
rx-element_at.hpp 74 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::element_at::element_at_observer
76 dest.on_next(v);
rx-filter.hpp 70 void on_next(Value&& v) const { function in struct:rxcpp::operators::detail::filter::filter_observer
79 dest.on_next(std::forward<Value>(v));
rx-finally.hpp 70 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::finally::finally_observer
71 dest.on_next(v);
rx-ignore_elements.hpp 55 void on_next(source_value_type) const { function in struct:rxcpp::operators::detail::ignore_elements::ignore_elements_observer
rx-map.hpp 70 void on_next(Value&& v) const { function in struct:rxcpp::operators::detail::map::map_observer
78 dest.on_next(std::move(selected.get()));
rx-on_error_resume_next.hpp 75 void on_next(value_type v) const { function in struct:rxcpp::operators::detail::on_error_resume_next::on_error_resume_next_observer
76 dest.on_next(std::move(v));
rx-pairwise.hpp 61 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::pairwise::pairwise_observer
67 dest.on_next(std::make_tuple(remembered.get(), v));
rx-skip_while.hpp 71 void on_next(source_value_type v) { function in struct:rxcpp::operators::detail::skip_while::skip_while_observer
75 dest.on_next(v);
rx-switch_if_empty.hpp 75 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::switch_if_empty::switch_if_empty_observer
77 dest.on_next(std::move(v));
rx-take_while.hpp 69 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::take_while::take_while_observer
71 dest.on_next(v);
rx-timestamp.hpp 78 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::timestamp::timestamp_observer
79 dest.on_next(std::make_pair(v, coord.now()));
rx-buffer_count.hpp 87 void on_next(T v) const { function in struct:rxcpp::operators::detail::buffer_count::buffer_count_observer
95 dest.on_next(std::move(chunks.front()));
106 dest.on_next(std::move(chunks.front()));
rx-delay.hpp 120 void on_next(T v) const { function in struct:rxcpp::operators::detail::delay::delay_observer
123 localState->dest.on_next(v);
rx-time_interval.hpp 82 void on_next(source_value_type) const { function in struct:rxcpp::operators::detail::time_interval::time_interval_observer
84 dest.on_next(now - last);
rx-window.hpp 87 dest.on_next(subj[0].get_observable().as_dynamic());
89 void on_next(T v) const { function in struct:rxcpp::operators::detail::window::window_observer
91 s.get_subscriber().on_next(v);
102 dest.on_next(subj[subj.size() - 1].get_observable().as_dynamic());
rx-window_toggle.hpp 138 // on_next
143 localState->dest.on_next(it->get_observable().as_dynamic());
173 // on_next
205 void on_next(T v) const { function in struct:rxcpp::operators::detail::window_toggle::window_toggle_observer
209 s.get_subscriber().on_next(v);
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
rx-behavior.hpp 61 void on_next(V v) const { function in class:rxcpp::subjects::detail::behavior_observer
63 base_type::on_next(std::move(v));
96 o.on_next(get_value());
rx-replaysubject.hpp 119 void on_next(V v) const { function in class:rxcpp::subjects::detail::replay_observer
121 base_type::on_next(std::move(v));
174 o.on_next(value);
  /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
lift.cpp 32 void on_next(typename dest_type::value_type v) const { function in struct:detail::liftfilter::filter_observer
41 dest.on_next(v);
252 if (pass) {dest.on_next(n);}
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-subscriber.hpp 54 that->destination.on_next(std::move(u));
176 void on_next(V&& v) const { function in class:rxcpp::subscriber
    [all...]

Completed in 159 milliseconds

1 2