reduce.cpp

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

 
int main()
{
    rpp::source::just(1, 2, 3)
        | rpp::operators::reduce(std::string{}, [](std::string&& seed, int v) { return std::move(seed) + std::to_string(v) + ","; })
        | rpp::operators::subscribe([](const std::string& v) { std::cout << v << std::endl; });
    // Output: 1,2,3,

    rpp::source::just(1, 2, 3)
        | rpp::operators::reduce(std::plus<int>{})
        | rpp::operators::subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 6
    return 0;
}