concat.cpp

#include <rpp/rpp.hpp>
 
#include "rpp/sources/fwd.hpp"
 
#include <iostream>

 
int main() // NOLINT(bugprone-exception-escape)
{
    rpp::source::concat(rpp::source::just(1), rpp::source::just(2), rpp::source::just(1, 2, 3)).subscribe([](int v) { std::cout << v << ", "; }, [](const std::exception_ptr&) { }, []() { std::cout << "completed\n"; });
    // Output: 1, 2, 1, 2, 3, completed

    auto observables = std::vector{rpp::source::just(1), rpp::source::just(2)};
    rpp::source::concat<rpp::memory_model::use_shared>(observables).subscribe([](int v) { std::cout << v << ", "; }, [](const std::exception_ptr&) { }, []() { std::cout << "completed\n"; });
    // Output: 1, 2, completed

    rpp::source::just(rpp::source::just(1).as_dynamic(),
                      rpp::source::just(2).as_dynamic(),
                      rpp::source::just(1, 2, 3).as_dynamic())
        | rpp::operators::concat()
        | rpp::operators::subscribe([](int v) { std::cout << v << ", "; }, [](const std::exception_ptr&) { }, []() { std::cout << "completed\n"; });
    // Output: 1, 2, 1, 2, 3, completed
}