Searched defs:produce_time (Results 1 – 4 of 4) sorted by relevance
109 auto produce_time = state->worker.now() + state->period; in buffer_with_time_or_count_observer() local150 auto produce_time = expected + state->period; in produce_buffer() local
132 auto produce_time = localState->worker.now() + localState->period; in timeout_observer() local167 auto produce_time = localState->worker.now() + localState->period; in on_next() local
111 auto produce_time = state->worker.now(); in window_with_time_or_count_observer() local154 auto produce_time = expected + state->period; in release_window() local
147 auto produce_time = localState->worker.now() + localState->period; in on_next() local