Lines Matching defs:source
8 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
10 auto values = source.take_until(trigger);
20 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7);
21 auto values = source.take_until(std::chrono::steady_clock::now() + std::chrono::milliseconds(25));
34 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){
35 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
42 auto values = source.take_until(trigger, rxcpp::observe_on_new_thread());
55 auto source = rxcpp::observable<>::interval(std::chrono::milliseconds(10)).take(7).map([](long v){
56 printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
60 auto values = source.take_until(scheduler.now() + std::chrono::milliseconds(25), scheduler);
