| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-test.hpp | 37 void on_subscribe(subscriber<T> o) const { in on_subscribe() function
42 on_subscribe(Subscriber o) 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-timer.hpp | 74 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-error.hpp | 65 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
|
| D | rx-scope.hpp | 73 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| 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-lift.hpp | 75 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-scan.hpp | 70 void on_subscribe(Subscriber o) const { in on_subscribe() function
|
| D | rx-skip_last.hpp | 68 void on_subscribe(const Subscriber& s) const { in on_subscribe() function
|
| D | rx-take_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-take.hpp | 74 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-merge.hpp | 100 void on_subscribe(Subscriber scbr) const { in on_subscribe() function
|
| D | rx-merge_delay_error.hpp | 93 void on_subscribe(Subscriber scbr) const { in on_subscribe() function
|
| D | rx-switch_on_next.hpp | 79 void on_subscribe(Subscriber scbr) const { in on_subscribe() function
|
| D | rx-take_until.hpp | 96 void on_subscribe(Subscriber s) 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
|