map.cpp

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

 
int main() // NOLINT(bugprone-exception-escape)
{
    rpp::source::just(42)
        | rpp::operators::map([](int value) { return value + 10; })
        | rpp::operators::subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 52

    rpp::source::just(42)
        | rpp::operators::map([](int value) { return std::to_string(value) + " VAL"; })
        | rpp::operators::subscribe([](const std::string& v) { std::cout << v << std::endl; });
    // Output: 42 VAL
    return 0;
}