Home
last modified time | relevance | path

Searched refs:produce_time (Results 1 – 4 of 4) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-buffer_time_count.hpp109 auto produce_time = state->worker.now() + state->period; in buffer_with_time_or_count_observer() local
137 …localState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulab… in buffer_with_time_or_count_observer()
138 localState->worker.schedule(produce_buffer(new_id, produce_time, localState)); in buffer_with_time_or_count_observer()
150 auto produce_time = expected + state->period; in produce_buffer() local
151 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in produce_buffer()
152 state->worker.schedule(produce_buffer(new_id, produce_time, state)); in produce_buffer()
Drx-window_time_count.hpp111 auto produce_time = state->worker.now(); in window_with_time_or_count_observer() local
139 …localState->worker.schedule(produce_time, [new_id, produce_time, localState](const rxsc::schedulab… in window_with_time_or_count_observer()
140 localState->worker.schedule(release_window(new_id, produce_time, localState)); in window_with_time_or_count_observer()
154 auto produce_time = expected + state->period; in release_window() local
155 … state->worker.schedule(produce_time, [new_id, produce_time, state](const rxsc::schedulable&){ in release_window()
156 state->worker.schedule(release_window(new_id, produce_time, state)); in release_window()
Drx-timeout.hpp132 auto produce_time = localState->worker.now() + localState->period; in timeout_observer() local
134 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in timeout_observer()
167 auto produce_time = localState->worker.now() + localState->period; in on_next() local
170 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in on_next()
Drx-debounce.hpp147 auto produce_time = localState->worker.now() + localState->period; in on_next() local
150 localState->worker.schedule(produce_time, produce_item(new_id, localState)); in on_next()