| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | replay.cpp | 35 auto worker = coordination.create_coordinator().get_worker();
92 auto worker = coordination.create_coordinator().get_worker();
149 auto worker = coordination.create_coordinator().get_worker();
206 auto worker = coordination.create_coordinator().get_worker();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-scheduler.hpp | 551 inline const worker get_worker() const { in get_worker() function in rxcpp::schedulers::schedulable
554 inline worker get_worker() { in get_worker() function in rxcpp::schedulers::schedulable
621 get_worker().schedule(*this); in schedule()
627 get_worker().schedule(when, *this); in schedule()
633 get_worker().schedule(when, *this); in schedule()
774 return schedulable(cs, scbl.get_worker(), make_action(std::forward<F>(f))); in make_schedulable()
784 return schedulable(scbl, scbl.get_worker(), make_action(std::forward<F>(f))); in make_schedulable()
789 return schedulable(cs, scbl.get_worker(), scbl.get_action()); in make_schedulable()
|
| D | rx-coordination.hpp | 85 rxsc::worker get_worker() const { in get_worker() function in rxcpp::coordinator
86 return input.get_worker(); in get_worker()
128 inline rxsc::worker get_worker() const { in get_worker() function in rxcpp::identity_one_worker::input_type
257 inline rxsc::worker get_worker() const { in get_worker() function in rxcpp::serialize_one_worker::input_type
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-synchronize.hpp | 91 auto processor = coordinator.get_worker(); in ensure_processing()
208 inline rxsc::worker get_worker() const { in get_worker() function in rxcpp::synchronize_in_one_worker::input_type
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 170 auto processor = coordinator.get_worker(); in ensure_processing()
277 inline rxsc::worker get_worker() const { in get_worker() function in rxcpp::observe_on_one_worker::input_type
|
| D | rx-subscribe_on.hpp | 98 auto controller = coordinator.get_worker(); in on_subscribe()
|
| D | rx-delay.hpp | 83 , worker(coordinator.get_worker()) in delay_subscriber_values()
|
| D | rx-sample_time.hpp | 83 , worker(coordinator.get_worker()) in sample_with_time_subscriber_value()
|
| D | rx-buffer_time_count.hpp | 91 , worker(coordinator.get_worker()) in buffer_with_time_or_count_subscriber_values()
|
| D | rx-debounce.hpp | 84 , worker(coordinator.get_worker()) in debounce_subscriber_values()
|
| D | rx-window_time_count.hpp | 91 , worker(coordinator.get_worker()) in window_with_time_or_count_subscriber_values()
|
| D | rx-timeout.hpp | 92 , worker(coordinator.get_worker()) in timeout_subscriber_values()
|
| D | rx-window_toggle.hpp | 97 , worker(coordinator.get_worker()) in window_toggle_subscriber_values()
|
| D | rx-window_time.hpp | 101 , worker(coordinator.get_worker()) in window_with_time_subscriber_values()
|
| D | rx-buffer_time.hpp | 109 , worker(coordinator.get_worker()) in buffer_with_time_subscriber_values()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-timer.hpp | 79 auto controller = coordinator.get_worker(); in on_subscribe()
|
| D | rx-error.hpp | 69 auto controller = coordinator.get_worker(); in on_subscribe()
|
| D | rx-range.hpp | 71 auto controller = coordinator.get_worker(); in on_subscribe()
|
| D | rx-interval.hpp | 77 auto controller = coordinator.get_worker(); in on_subscribe()
|
| D | rx-iterate.hpp | 121 auto controller = coordinator.get_worker(); in on_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 156 auto ew = es.create_coordinator().get_worker(); in __anonfe564e910a02()
265 auto ew = es.create_coordinator().get_worker(); in __anonfe564e911602()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-virtualtime.hpp | 210 a.get_worker(), in schedule_absolute()
|