Searched refs:produce_time (Results 1 – 4 of 4) sorted by relevance
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
D | rx-buffer_time_count.hpp | 109 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()
|
D | rx-window_time_count.hpp | 111 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()
|
D | rx-timeout.hpp | 132 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()
|
D | rx-debounce.hpp | 147 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()
|