Searched refs:produce_at (Results 1 – 2 of 2) sorted by relevance
165 auto produce_at = localState->expected + localState->period; in buffer_with_time_observer() local167 … localState->worker.schedule(produce_at, [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer()
161 auto produce_at = localState->expected + localState->period; in window_with_time_observer() local163 … localState->worker.schedule(produce_at, [localState, selectedRelease](const rxsc::schedulable&) { in window_with_time_observer()