merge.cpp

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

int main()
{
    rpp::source::just(rpp::source::just(1).as_dynamic(),
                      rpp::source::never<int>().as_dynamic(),
                      rpp::source::just(2).as_dynamic())
        | rpp::operators::merge()
        | rpp::operators::subscribe([](int v) { std::cout << v << " "; });
    // Output: 1 2

    rpp::source::just(1)
        | rpp::operators::merge_with(rpp::source::just(2))
        | rpp::operators::subscribe([](int v) { std::cout << v << " "; });
    // Output: 1 2
    return 0;
}