defer.cpp

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

 
int main() // NOLINT(bugprone-exception-escape)
{
    rpp::source::defer([] {
        std::cout << "Observable factory called\n";
        return rpp::source::from_iterable(std::array{ 1,2,3 }); })
        .subscribe([](int v) { std::cout << v << "\n"; }, rpp::utils::rethrow_error_t{}, []() { std::cout << "On complete\n"; });
    // Output: Observable factory called
    //         1
    //         2
    //         3
    //         On complete

    auto obs = rpp::source::defer([] {
        std::cout << "Observable factory called\n";
        const auto state     = std::make_shared<int>(0);
        auto       inner_obs = rpp::source::create<int>([state](const auto& obs) {
            obs.on_next((*state)++);
            obs.on_completed();
        });
        return inner_obs;
    });
    obs.subscribe([](int v) { std::cout << v << "\n"; }, rpp::utils::rethrow_error_t{}, []() { std::cout << "On complete\n"; });
    obs.subscribe([](int v) { std::cout << v << "\n"; }, rpp::utils::rethrow_error_t{}, []() { std::cout << "On complete\n"; });
    // Output: Observable factory called
    //         0
    //         On complete
    //         Observable factory called
    //         0
    //         On complete
}