docs/html/take_while_8cpp-example.html

#include <rpp/rpp.hpp>


#include <iostream>


int main() // NOLINT(bugprone-exception-escape)

{

    rpp::source::just(0, 1, 2, 3, 4, 5, 6, 7, 8, 9)

        | rpp::operators::take_while([](int v) { return v != 5; })

        | rpp::operators::subscribe([](int v) { std::cout << v << " "; });

    // Output: 0 1 2 3 4

    return 0;

}

rpp::operators::take_while
auto take_while(Fn &&predicate)
Sends items from observable while items are satisfy predicate. When condition becomes false -> sends ...
Definition take_while.hpp:91

rpp::source::just
auto just(const TScheduler &scheduler, T &&item, Ts &&... items)
Creates rpp::observable that emits a particular items and completes.
Definition from.hpp:201

rpp::operators::subscribe
auto subscribe(observer< Type, ObserverStrategy > &&observer)
Subscribes passed observer to emissions from this observable.
Definition subscribe.hpp:226