Searched refs:selectedCreate (Results 1 – 2 of 2) sorted by relevance
171 auto selectedCreate = on_exception( in buffer_with_time_observer() local174 if (selectedCreate.empty()) { in buffer_with_time_observer()181 [localState, selectedCreate](const rxsc::schedulable&) { in buffer_with_time_observer()182 localState->worker.schedule(selectedCreate.get()); in buffer_with_time_observer()
167 auto selectedCreate = on_exception( in window_with_time_observer() local170 if (selectedCreate.empty()) { in window_with_time_observer()177 [localState, selectedCreate](const rxsc::schedulable&) { in window_with_time_observer()178 localState->worker.schedule(selectedCreate.get()); in window_with_time_observer()