| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 12 s.on_completed(); in __anona11559230102()
41 s.on_completed(); in __anona11559230602()
68 s.on_completed(); in __anona11559230902()
84 s.on_completed(); in __anona11559230a02()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | observer.cpp | 54 scrbResult.on_completed();
164 dob.on_completed();
168 so.on_completed();
172 dob.on_completed();
176 so.on_completed();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window.hpp | 96 subj[0].get_subscriber().on_completed(); in on_next()
113 void on_completed() const { in on_completed() function
115 s.get_subscriber().on_completed(); in on_completed()
117 dest.on_completed(); in on_completed()
|
| D | rx-take_while.hpp | 73 dest.on_completed(); in on_next()
79 void on_completed() const { in on_completed() function
80 dest.on_completed(); in on_completed()
|
| D | rx-tap.hpp | 99 void on_completed() const { in on_completed() function
100 out.on_completed(); in on_completed()
101 dest.on_completed(); in on_completed()
|
| D | rx-all.hpp | 83 dest.on_completed(); in on_next()
89 void on_completed() const { in on_completed() function
93 dest.on_completed(); in on_completed()
|
| D | rx-any.hpp | 90 dest.on_completed(); in on_next()
96 void on_completed() const { in on_completed() function
100 dest.on_completed(); in on_completed()
|
| D | rx-ignore_elements.hpp | 63 void on_completed() const { in on_completed() function
64 dest.on_completed(); in on_completed()
|
| D | rx-distinct.hpp | 67 void on_completed() const { in on_completed() function
68 dest.on_completed(); in on_completed()
|
| D | rx-repeat.hpp | 55 static inline void on_completed(State& state) { in on_completed() function
59 state->out.on_completed(); in on_completed()
|
| D | rx-pairwise.hpp | 73 void on_completed() const { in on_completed() function
74 dest.on_completed(); in on_completed()
|
| D | rx-finally.hpp | 76 void on_completed() const { in on_completed() function
77 dest.on_completed(); in on_completed()
|
| D | rx-retry.hpp | 57 static inline void on_completed(State& state) { in on_completed() function
58 state->out.on_completed(); in on_completed()
|
| D | rx-skip_while.hpp | 81 void on_completed() const { in on_completed() function
82 dest.on_completed(); in on_completed()
|
| D | rx-element_at.hpp | 77 dest.on_completed(); in on_next()
83 void on_completed() const { in on_completed() function
|
| D | rx-window_time_count.hpp | 149 state->subj.get_subscriber().on_completed(); in release_window()
201 void on_completed() const { in on_completed() function
204 localState->subj.get_subscriber().on_completed(); in on_completed()
205 localState->dest.on_completed(); in on_completed()
|
| D | rx-retry-repeat-common.hpp | 50 EventHandlers::on_completed(state); in do_subscribe()
100 state->out.on_completed(); in on_subscribe()
|
| D | rx-filter.hpp | 85 void on_completed() const { in on_completed() function
86 dest.on_completed(); in on_completed()
|
| D | rx-window_toggle.hpp | 162 it->get_subscriber().on_completed(); in window_toggle_observer()
238 void on_completed() const { in on_completed() function
242 s.get_subscriber().on_completed(); in on_completed()
244 localState->dest.on_completed(); in on_completed()
|
| D | rx-distinct_until_changed.hpp | 80 void on_completed() const { in on_completed() function
81 dest.on_completed(); in on_completed()
|
| D | rx-take.hpp | 110 state->out.on_completed(); in on_subscribe()
122 state->out.on_completed(); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-synchronize.hpp | 121 void on_completed() const { in on_completed() function
124 fill_queue.push_back(notification_type::on_completed()); in on_completed()
156 void on_completed() const { in on_completed() function in rxcpp::subjects::detail::synchronize_observer
157 state->on_completed(); in on_completed()
|
| D | rx-subject.hpp | 154 o.on_completed(); in add()
213 void on_completed() const { in on_completed() function in rxcpp::subjects::detail::multicast_observer
224 o.on_completed(); in on_completed()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | lift.cpp | 47 void on_completed() const { in on_completed() function
48 dest.on_completed(); in on_completed()
255 [=](){dest.on_completed();})); in __anon42c5b5c00602()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observer.hpp | 110 s.on_completed(); in operator ()()
250 void on_completed() const { in on_completed() function in rxcpp::observer
338 void on_completed() const { in on_completed() function in rxcpp::observer
356 virtual void on_completed() const {}; in on_completed() function
377 virtual void on_completed() const { in on_completed() function
378 destination.on_completed(); in on_completed()
447 void on_completed() const { in on_completed() function in rxcpp::observer
449 destination->on_completed(); in on_completed()
|