Lines Matching refs:rxcpp

8     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;});  in __anonbf9fecff0102()
9     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;});  in __anonbf9fecff0202()
10     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;});  in __anonbf9fecff0302()
21     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;});  in __anonbf9fecff0602()
22     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;});  in __anonbf9fecff0702()
23     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;});  in __anonbf9fecff0802()
24     auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {  in __anonbf9fecff0b02()
42     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {  in __anonbf9fecff0c02()
46     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {  in __anonbf9fecff0d02()
50     auto values = o1.amb(rxcpp::observe_on_new_thread(), o2, o3);
63     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {  in __anonbf9fecff1002()
67     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {  in __anonbf9fecff1102()
71     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {  in __anonbf9fecff1202()
75     auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
76     auto values = base.amb(rxcpp::observe_on_new_thread());