OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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