distinct_until_changed.cpp

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

 
int main()
{
    rpp::source::just(1, 1, 2, 2, 3, 2, 1)
        | rpp::operators::distinct_until_changed()
        | rpp::operators::subscribe([](int val) { std::cout << val << " "; });
    // Output: 1 2 3 2 1
 
    std::cout << std::endl;
    rpp::source::just(1, 1, 2, 2, 3, 2, 1)
        | rpp::operators::distinct_until_changed([](int left, int right) { return left != right; })
        | rpp::operators::subscribe([](int val) { std::cout << val << " "; });
    // Output: 1 1 1
    return 0;
}