Lines Matching refs:rxcpp
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…
45 window_with_time(period, skip, rxcpp::observe_on_new_thread());
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…
123 window_with_time(std::chrono::milliseconds(4), rxcpp::observe_on_new_thread());
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));
162 window_with_time_or_count(std::chrono::milliseconds(20), 2, rxcpp::observe_on_event_loop());
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()
206 rxcpp::observe_on_new_thread());
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()