Home
last modified time | relevance | path

Searched refs:selectedDisposer (Results 1 – 9 of 9) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe_on.hpp111 auto selectedDisposer = on_exception( in on_subscribe() local
114 if (selectedDisposer.empty()) { in on_subscribe()
119 controller.schedule(selectedDisposer.get()); in on_subscribe()
Drx-delay.hpp105 auto selectedDisposer = on_exception( in delay_observer() local
108 if (selectedDisposer.empty()) { in delay_observer()
113 localState->worker.schedule(selectedDisposer.get()); in delay_observer()
116 …localState->worker.schedule(localState->worker.now() + localState->period, selectedDisposer.get()); in delay_observer()
Drx-sample_time.hpp104 auto selectedDisposer = on_exception( in sample_with_time_observer() local
107 if (selectedDisposer.empty()) { in sample_with_time_observer()
112 localState->worker.schedule(selectedDisposer.get()); in sample_with_time_observer()
115 localState->worker.schedule(selectedDisposer.get()); in sample_with_time_observer()
Drx-buffer_time_count.hpp117 auto selectedDisposer = on_exception( in buffer_with_time_or_count_observer() local
120 if (selectedDisposer.empty()) { in buffer_with_time_or_count_observer()
125 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
128 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_or_count_observer()
Drx-debounce.hpp109 auto selectedDisposer = on_exception( in debounce_observer() local
112 if (selectedDisposer.empty()) { in debounce_observer()
117 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()
120 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()
Drx-window_time_count.hpp119 auto selectedDisposer = on_exception( in window_with_time_or_count_observer() local
122 if (selectedDisposer.empty()) { in window_with_time_or_count_observer()
127 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
130 localState->worker.schedule(selectedDisposer.get()); in window_with_time_or_count_observer()
Drx-timeout.hpp116 auto selectedDisposer = on_exception( in timeout_observer() local
119 if (selectedDisposer.empty()) { in timeout_observer()
124 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
127 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
Drx-window_time.hpp124 auto selectedDisposer = on_exception( in window_with_time_observer() local
127 if (selectedDisposer.empty()) { in window_with_time_observer()
132 localState->worker.schedule(selectedDisposer.get()); in window_with_time_observer()
135 localState->worker.schedule(selectedDisposer.get()); in window_with_time_observer()
Drx-buffer_time.hpp132 auto selectedDisposer = on_exception( in buffer_with_time_observer() local
135 if (selectedDisposer.empty()) { in buffer_with_time_observer()
140 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_observer()
143 localState->worker.schedule(selectedDisposer.get()); in buffer_with_time_observer()