Lines Matching refs:observable

9     auto values = rxcpp::observable<>::range(1, 5).window(2);
12             [&counter](rxcpp::observable<int> v){  in __anon5e81ce600102()
25     auto values = rxcpp::observable<>::range(1, 7).window(2, 3);
28             [&counter](rxcpp::observable<int> v){  in __anon5e81ce600402()
43 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
49             [&counter](rxcpp::observable<long> v){  in __anon5e81ce600702()
64 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
69             [&counter](rxcpp::observable<long> v){  in __anon5e81ce600a02()
84 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
89             [&counter](rxcpp::observable<long> v){  in __anon5e81ce600d02()
104     auto values = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).
108             [&counter](rxcpp::observable<long> v){  in __anon5e81ce601002()
121 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
127             [&counter](rxcpp::observable<long> v){  in __anon5e81ce601302()
140 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
145             [&counter](rxcpp::observable<long> v){  in __anon5e81ce601602()
158     auto int1 = rxcpp::observable<>::range(1L, 3L);
159     auto int2 = rxcpp::observable<>::timer(std::chrono::milliseconds(50));
166             [&counter](rxcpp::observable<long> v){  in __anon5e81ce601902()
179     auto int1 = rxcpp::observable<>::range(1L, 3L);
180     auto int2 = rxcpp::observable<>::timer(std::chrono::milliseconds(50));
186             [&counter](rxcpp::observable<long> v){  in __anon5e81ce601c02()
199 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
202             rxcpp::observable<>::interval(std::chrono::milliseconds(4)), 
204                 return rxcpp::observable<>::interval(std::chrono::milliseconds(4)).skip(1);  in __anon5e81ce601f02()
210             [&counter](rxcpp::observable<long> v){  in __anon5e81ce602002()
223 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
226             rxcpp::observable<>::interval(std::chrono::milliseconds(4)), 
228                 return rxcpp::observable<>::interval(std::chrono::milliseconds(4)).skip(1);  in __anon5e81ce602302()
232             [&counter](rxcpp::observable<long> v){  in __anon5e81ce602402()