| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-behavior.hpp | 52 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::detail::behavior_observer
88 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::behavior
89 return s.get_subscriber(); in get_subscriber()
98 keepAlive.add(s.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-replaysubject.hpp | 106 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::detail::replay_observer
166 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::replay
167 return s.get_subscriber(); in get_subscriber()
176 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-subject.hpp | 124 input_subscriber_type get_subscriber() const { in get_subscriber() function in rxcpp::subjects::detail::multicast_observer
261 subscriber_type get_subscriber() const { in get_subscriber() function in rxcpp::subjects::subject
262 return s.get_subscriber(); in get_subscriber()
268 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| D | rx-synchronize.hpp | 145 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::detail::synchronize_observer
178 subscriber<T> get_subscriber() const { in get_subscriber() function in rxcpp::subjects::synchronize
179 return s.get_subscriber(); in get_subscriber()
185 keepAlive.add(keepAlive.get_subscriber(), std::move(o)); in get_observable()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-window.hpp | 91 s.get_subscriber().on_next(v); in on_next()
96 subj[0].get_subscriber().on_completed(); in on_next()
108 s.get_subscriber().on_error(e); in on_error()
115 s.get_subscriber().on_completed(); in on_completed()
|
| D | rx-window_time_count.hpp | 149 state->subj.get_subscriber().on_completed(); in release_window()
172 localState->subj.get_subscriber().on_next(v); in on_next()
189 localState->subj.get_subscriber().on_error(e); in on_error()
204 localState->subj.get_subscriber().on_completed(); in on_completed()
|
| D | rx-window_toggle.hpp | 162 it->get_subscriber().on_completed(); in window_toggle_observer()
209 s.get_subscriber().on_next(v); in on_next()
225 s.get_subscriber().on_error(e); in on_error()
242 s.get_subscriber().on_completed(); in on_completed()
|
| D | rx-window_time.hpp | 146 localState->subj[0].get_subscriber().on_completed(); in window_with_time_observer()
186 s.get_subscriber().on_next(v); in on_next()
202 s.get_subscriber().on_error(e); in on_error()
219 s.get_subscriber().on_completed(); in on_completed()
|
| D | rx-multicast.hpp | 65 auto destination = state->subject_value.get_subscriber(); in on_connect()
|
| D | rx-group_by.hpp | 213 … g = state->groups.insert(std::make_pair(selectedKey.get(), sub.get_subscriber())).first; in on_next()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 317 auto o = sub.get_subscriber();
390 auto o = sub.get_subscriber();
488 auto o = s.get_subscriber();
491 s = rxsub::subject<int>(); o = s.get_subscriber(); checks.clear(); record(100);}); in __anon0164c1a71c02()
595 auto o = s.get_subscriber();
598 s = rxsub::subject<int>(); o = s.get_subscriber();}); in __anon0164c1a72602()
688 auto o = s.get_subscriber();
691 s = rxsub::subject<int>(); o = s.get_subscriber();}); in __anon0164c1a73002()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coordination.hpp | 60 struct get_subscriber struct in rxcpp::coordinator
80 … is_subscriber<T>::value, get_subscriber<T>, not_supported>::type>::type>::type::type type;
101 -> typename get_subscriber<Subscriber>::type { in out()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/win_text/ |
| D | rx_windows_user.h | 67 rx_messages() : sub(subject.get_subscriber()) {} in rx_messages()
|