Lines Matching defs:source
9 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
21 auto source = rxcpp::observable<>::from(1, 2).
22 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
23 auto values = source.retry(3);
40 // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error1 from source"))).
42 // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error2 from source"))).
44 // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error3 from source"))).
46 // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error4 from source"))).
63 // auto source = rxcpp::observable<>::from(1, 2).
64 // concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
66 // auto values = source.retry();
68 // // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error1 from source"))).
70 // // concat(rxcpp::observable<>::error<long>(std::runtime_error("Error2 from source"))).
