Lines Matching refs:rxcpp

8     auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
9     auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
10     auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
25     auto thr = rxcpp::synchronize_event_loop();
26     auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1)).map([](int v) {  in __anon3bb890620302()
30     auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) {  in __anon3bb890620402()
34     auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) {  in __anon3bb890620502()
51     auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
52     auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
53     auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
54     auto values = o1 | rxcpp::operators::zip(
69     auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
70     auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
71     auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
73         rxcpp::observe_on_new_thread(),