10 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
23     rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){  in __anon3e0ec51c0302()
34     auto coordination = rxcpp::serialize_new_thread();
36     auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
41     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c0602()
48 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::…  in __anon3e0ec51c0902()
55     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c0c02()
67 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
80     rxcpp::observable<>::timer(std::chrono::milliseconds(125)).subscribe([&](long){  in __anon3e0ec51c0f02()
91     auto coordination = rxcpp::serialize_new_thread();
93     auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
98     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c1202()
105 …worker.schedule(coordination.now() + std::chrono::milliseconds(125), [&](const rxcpp::schedulers::…  in __anon3e0ec51c1502()
112     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c1802()
124 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
137     rxcpp::observable<>::timer(std::chrono::milliseconds(175)).subscribe([&](long){  in __anon3e0ec51c1b02()
148     auto coordination = rxcpp::serialize_new_thread();
150     auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
155     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c1e02()
162 …worker.schedule(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::…  in __anon3e0ec51c2102()
169     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c2402()
181 …auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50), rxcpp::observe_on_new_t…
194     rxcpp::observable<>::timer(std::chrono::milliseconds(175)).subscribe([&](long){  in __anon3e0ec51c2702()
205     auto coordination = rxcpp::serialize_new_thread();
207     auto values = rxcpp::observable<>::interval(std::chrono::milliseconds(50)).
212     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c2a02()
219 …worker.schedule(coordination.now() + std::chrono::milliseconds(175), [&](const rxcpp::schedulers::…  in __anon3e0ec51c2d02()
226     worker.schedule([&](const rxcpp::schedulers::schedulable&){  in __anon3e0ec51c3002()