interval.cpp

#include <rpp/rpp.hpp>
 
#include <chrono>
#include <iostream>

 
int main() // NOLINT(bugprone-exception-escape)
{
    rpp::source::interval(std::chrono::milliseconds(10), rpp::schedulers::immediate{})
        | rpp::operators::take(3)
        | rpp::operators::subscribe(
            [start = rpp::schedulers::clock_type::now()](size_t v) { std::cout << "emit " << v << " duration since start " << std::chrono::duration_cast<std::chrono::milliseconds>(rpp::schedulers::clock_type::now() - start).count() << "ms\n"; },
            rpp::utils::rethrow_error_t{},
            []() { std::cout << "On complete\n"; });
    // Output: Observable factory called
    //    emit 1 duration since start 0ms
    //    emit 2 duration since start 10ms
    //    emit 3 duration since start 20ms
    //    On complete

    rpp::source::interval(std::chrono::milliseconds(5), std::chrono::milliseconds(10), rpp::schedulers::immediate{})
        | rpp::operators::take(3)
        | rpp::operators::subscribe(
            [start = rpp::schedulers::clock_type::now()](size_t v) { std::cout << "emit " << v << " duration since start " << std::chrono::duration_cast<std::chrono::milliseconds>(rpp::schedulers::clock_type::now() - start).count() << "ms\n"; },
            rpp::utils::rethrow_error_t{},
            []() { std::cout << "On complete\n"; });
    // Output: Observable factory called
    //    emit 1 duration since start 5ms
    //    emit 2 duration since start 15ms
    //    emit 3 duration since start 25ms
    //    On complete
}