Lines Matching refs:rxcpp

8     auto ints = rxcpp::observable<>::create<int>(
9         [](rxcpp::subscriber<int> s){  in __anona11559230102()
24     auto subscription = rxcpp::composite_subscription();
25     auto subscriber = rxcpp::make_subscriber<int>(
35     rxcpp::observable<>::create<int>(
36         [](rxcpp::subscriber<int> s){  in __anona11559230602()
49     auto subscription = rxcpp::composite_subscription();
50     auto subscriber = rxcpp::make_subscriber<int>(
60     rxcpp::observable<>::create<int>(
61         [](rxcpp::subscriber<int> s){  in __anona11559230902()
76     auto ints = rxcpp::observable<>::create<int>(
77         [](rxcpp::subscriber<int> s){  in __anona11559230a02()
93             [](rxcpp::util::error_ptr ep){  in __anona11559230c02()
94                 printf("OnError: %s\n", rxcpp::util::what(ep).c_str());  in __anona11559230c02()