Searched refs:selectedDisposer (Results 1 – 9 of 9) sorted by relevance
111 auto selectedDisposer = on_exception( in on_subscribe() local114 if (selectedDisposer.empty()) { in on_subscribe()119 controller.schedule(selectedDisposer.get()); in on_subscribe()
104 auto selectedDisposer = on_exception( in sample_with_time_observer() local107 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()
105 auto selectedDisposer = on_exception( in delay_observer() local108 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()
117 auto selectedDisposer = on_exception( in buffer_with_time_or_count_observer() local120 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()
116 auto selectedDisposer = on_exception( in timeout_observer() local119 if (selectedDisposer.empty()) { in timeout_observer()124 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()127 localState->worker.schedule(selectedDisposer.get()); in timeout_observer()
119 auto selectedDisposer = on_exception( in window_with_time_or_count_observer() local122 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()
109 auto selectedDisposer = on_exception( in debounce_observer() local112 if (selectedDisposer.empty()) { in debounce_observer()117 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()120 localState->worker.schedule(selectedDisposer.get()); in debounce_observer()
132 auto selectedDisposer = on_exception( in buffer_with_time_observer() local135 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()
124 auto selectedDisposer = on_exception( in window_with_time_observer() local127 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()