| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-test.hpp | 22 virtual void on_subscribe(subscriber<T>) const =0;
37 void on_subscribe(subscriber<T> o) const { in on_subscribe() function
38 ts->on_subscribe(std::move(o)); in on_subscribe()
42 on_subscribe(Subscriber o) const { in on_subscribe() function
46 ts->on_subscribe(o.as_dynamic()); in on_subscribe()
|
| D | rx-observable.hpp | 25 static auto check(int) -> decltype((*(CT*)nullptr).on_subscribe(*(CS*)nullptr));
44 onsubscribe_type on_subscribe; member
54 state->on_subscribe = [so](subscriber<T> o) mutable { in construct()
55 so.on_subscribe(std::move(o)); in construct()
62 state->on_subscribe = std::forward<F>(f); in construct()
81 void on_subscribe(subscriber<T> o) const { in on_subscribe() function in rxcpp::dynamic_observable
82 state->on_subscribe(std::move(o)); in on_subscribe()
87 on_subscribe(Subscriber o) const { in on_subscribe() function in rxcpp::dynamic_observable
88 state->on_subscribe(o.as_dynamic()); in on_subscribe()
439 so->on_subscribe(*o); in subscribe()
[all …]
|
| D | rx-grouped_observable.hpp | 91 using dynamic_observable<T>::on_subscribe;
|
| D | rx-connectable_observable.hpp | 85 using dynamic_observable<T>::on_subscribe;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-lift.hpp | 75 void on_subscribe(Subscriber o) const { in on_subscribe() function
78 source.on_subscribe(std::move(lifted)); in on_subscribe()
|
| D | rx-retry-repeat-common.hpp | 94 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
137 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-connect_forever.hpp | 48 void on_subscribe(Subscriber&& o) const { in on_subscribe() function
|
| D | rx-multicast.hpp | 60 void on_subscribe(Subscriber&& o) const { in on_subscribe() function
|
| D | rx-take.hpp | 74 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-skip_last.hpp | 68 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-skip.hpp | 75 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-scan.hpp | 70 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-take_last.hpp | 68 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-subscribe_on.hpp | 76 void on_subscribe(Subscriber s) const { in on_subscribe() function
|
| D | rx-ref_count.hpp | 147 void on_subscribe(Subscriber&& o) const { in on_subscribe() function
|
| D | rx-switch_on_next.hpp | 79 void on_subscribe(Subscriber scbr) const { in on_subscribe() function
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-never.hpp | 33 void on_subscribe(Subscriber) const { in on_subscribe() function
|
| D | rx-create.hpp | 66 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-defer.hpp | 55 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-scope.hpp | 73 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-timer.hpp | 74 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-error.hpp | 65 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-interval.hpp | 71 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-range.hpp | 65 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 175 virtual void on_subscribe(subscriber<T>) const { in on_subscribe() function in rxcpp::schedulers::detail::mock_observer
244 virtual void on_subscribe(subscriber<T> o) const { in on_subscribe() function in rxcpp::schedulers::detail::cold_observable
318 virtual void on_subscribe(observer_type o) const { in on_subscribe() function in rxcpp::schedulers::detail::hot_observable
|