Lines Matching refs:observable

8     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;});  in __anona9b065b80102()
9     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;});  in __anona9b065b80202()
10     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;});  in __anona9b065b80302()
21     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;});  in __anona9b065b80602()
22     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;});  in __anona9b065b80702()
23     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;});  in __anona9b065b80802()
24     auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {  in __anona9b065b80b02()
42     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).map([](int) {  in __anona9b065b80c02()
46     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(30)).map([](int) {  in __anona9b065b80d02()
63     auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {  in __anona9b065b81002()
67     auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).map([](int) {  in __anona9b065b81102()
71     auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(30)).map([](int) {  in __anona9b065b81202()
75     auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);