ReactivePlusPlus
ReactiveX implementation for C++20
Toggle main menu visibility
Loading...
Searching...
No Matches
skip.cpp
#include <rpp/rpp.hpp>
#include <iostream>
int
main()
{
rpp::source::just
(0, 1, 2, 3, 4, 5)
|
rpp::operators::skip
(2)
|
rpp::operators::subscribe
([](
int
v) { std::cout << v <<
" "
; });
// Output: 2 3 4 5
return
0;
}
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::skip
auto skip(size_t count)
Skip first count items provided by observable then send rest items as expected.
Definition
skip.hpp:89
rpp::operators::subscribe
auto subscribe(observer< Type, ObserverStrategy > &&observer)
Subscribes passed observer to emissions from this observable.
Definition
subscribe.hpp:226
Generated by
1.17.0