first.cpp

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

int main()
{
    rpp::source::just(1, 2, 3, 4, 5)
        | rpp::operators::first()
        | rpp::operators::subscribe(
            [](const auto& v) { std::cout << "-" << v; },
            [](const std::exception_ptr&) {},
            []() { std::cout << "-|" << std::endl; });
    // Source: -1-2-3-4-5--|
    // Output: -1-|

    rpp::source::empty<int>()
        | rpp::operators::first()
        | rpp::operators::subscribe(
            [](const auto& v) { std::cout << "-" << v; },
            [](const std::exception_ptr&) { std::cout << "-x" << std::endl; },
            []() { std::cout << "-|" << std::endl; });
    // Source: -1-2-3-4-5--|
    // Output: -x
    return 0;
}