Lines Matching refs:coordination
34 auto coordination = rxcpp::serialize_new_thread(); variable
35 auto worker = coordination.create_coordinator().get_worker();
38 replay(coordination);
48 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anon982cbcb50902()
91 auto coordination = rxcpp::serialize_new_thread(); variable
92 auto worker = coordination.create_coordinator().get_worker();
95 replay(2, coordination);
105 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::… in __anon982cbcb51502()
148 auto coordination = rxcpp::serialize_new_thread(); variable
149 auto worker = coordination.create_coordinator().get_worker();
152 replay(std::chrono::milliseconds(125), coordination);
162 …worker.schedule(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::… in __anon982cbcb52102()
205 auto coordination = rxcpp::serialize_new_thread(); variable
206 auto worker = coordination.create_coordinator().get_worker();
209 replay(2, std::chrono::milliseconds(125), coordination);
219 …worker.schedule(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::… in __anon982cbcb52d02()