Function main

src/examples/rpp/doxygen/defer.cpp:9–42

 **/

int main() // NOLINT(bugprone-exception-escape)
{
    //! [defer from_iterable]
    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
    //! [defer from_iterable]

    //! [defer mutable source]
    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
    //! [defer mutable source]
}