take.cpp

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

int main() // NOLINT(bugprone-exception-escape)
{
    rpp::source::from_iterable(std::vector{0, 1, 2, 3, 4})
        | rpp::operators::take(2)
        | rpp::operators::subscribe([](int v) { std::cout << v << " "; });
    // Output: 0 1
    return 0;
}