Searched refs:selectedProduce (Results 1 – 5 of 5) sorted by relevance
156 auto selectedProduce = on_exception( in buffer_with_time_observer() local159 if (selectedProduce.empty()) { in buffer_with_time_observer()163 auto create_buffer = [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer()167 … localState->worker.schedule(produce_at, [localState, selectedProduce](const rxsc::schedulable&) { in buffer_with_time_observer()168 localState->worker.schedule(selectedProduce.get()); in buffer_with_time_observer()
124 auto selectedProduce = on_exception( in sample_with_time_observer() local127 if (selectedProduce.empty()) { in sample_with_time_observer()134 [localState, selectedProduce](const rxsc::schedulable&) { in sample_with_time_observer()135 localState->worker.schedule(selectedProduce.get()); in sample_with_time_observer()
153 auto selectedProduce = on_exception( in produce_timeout() local156 if (selectedProduce.empty()) { in produce_timeout()160 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_timeout()
156 auto selectedProduce = on_exception( in produce_buffer() local159 if (selectedProduce.empty()) { in produce_buffer()163 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_buffer()
133 auto selectedProduce = on_exception( in produce_item() local136 if (selectedProduce.empty()) { in produce_item()140 return std::function<void(const rxsc::schedulable&)>(selectedProduce.get()); in produce_item()