Lines Matching refs:observable

8     auto values = rxcpp::observable<>::range(1, 3).first();
19     auto values = rxcpp::observable<>::empty<int>().first();
36     auto values = rxcpp::observable<>::range(1, 3).last();
47     auto values = rxcpp::observable<>::empty<int>().last();
64     auto values = rxcpp::observable<>::range(1, 3).count();
75     auto values = rxcpp::observable<>::range(1, 3).
76         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
94     auto values = rxcpp::observable<>::range(1, 3).sum();
105     auto values = rxcpp::observable<>::empty<int>().sum();
122     auto values = rxcpp::observable<>::range(1, 3).
123         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
140     auto values = rxcpp::observable<>::range(1, 4).average();
151     auto values = rxcpp::observable<>::empty<int>().average();
168     auto values = rxcpp::observable<>::range(1, 4).
169         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
186     auto values = rxcpp::observable<>::range(1, 4).max();
197     auto values = rxcpp::observable<>::empty<int>().max();
214     auto values = rxcpp::observable<>::range(1, 4).
215         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
232     auto values = rxcpp::observable<>::range(1, 4).min();
243     auto values = rxcpp::observable<>::empty<int>().min();
260     auto values = rxcpp::observable<>::range(1, 4).
261         concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).