Searched refs:release_window (Results 1 – 2 of 2) sorted by relevance
140 localState->worker.schedule(release_window(new_id, produce_time, localState)); in window_with_time_or_count_observer()144 …static std::function<void(const rxsc::schedulable&)> release_window(int id, rxsc::scheduler::clock… in release_window() function156 state->worker.schedule(release_window(new_id, produce_time, state)); in release_window()174 release_window(localState->subj_id, localState->worker.now(), localState)(self); in on_next()
144 auto release_window = [localState](const rxsc::schedulable&) { in window_with_time_observer() local151 [&](){return localState->coordinator.act(release_window);}, in window_with_time_observer()