Lines Matching refs:rxcpp

8     auto subscriber = rxcpp::make_subscriber<int>(
11     auto values = rxcpp::observable<>::range(1, 3);
18     auto subscriber = rxcpp::make_subscriber<int>(
21     auto values1 = rxcpp::observable<>::range(1, 3);
22     auto values2 = rxcpp::observable<>::range(4, 6);
30     auto values = rxcpp::observable<>::range(1, 3);
38     auto values = rxcpp::observable<>::range(1, 3).
39         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
53     auto values = rxcpp::observable<>::range(1, 3);
62     auto subscription = rxcpp::composite_subscription();
63     auto values = rxcpp::observable<>::range(1, 5);
77     auto values = rxcpp::observable<>::range(1, 3).
78         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
93     auto values = rxcpp::observable<>::range(1, 3).
94         concat(rxcpp::observable<>::never<int>()).