ReactivePlusPlus
ReactiveX implementation for C++20
Loading...
Searching...
No Matches
start_with.cpp
#include <rpp/rpp.hpp>
#include <iostream>
int main()
{
| rpp::ops::subscribe([](int v) { std::cout << v << " "; });
// Output: 5 6 1 2 3
| rpp::ops::subscribe([](int v) { std::cout << v << " "; });
// Output: 5 6 1 2 3
| rpp::ops::subscribe([](int v) { std::cout << v << " "; });
// Output: 5 6 1
return 0;
}
auto merge()
Converts observable of observables of items into observable of items via merging emissions.
Definition merge.hpp:221
auto start_with_values(T &&v, Ts &&... vals)
Combines submissions from current observable with values into one but without overlapping and startin...
Definition start_with.hpp:112
auto start_with(TObservable &&observable, TObservables &&... observables)
Combines submissions from current observable with other observables into one but without overlapping ...
Definition start_with.hpp:85
auto just(const TScheduler &scheduler, T &&item, Ts &&... items)
Creates rpp::observable that emits a particular items and completes.
Definition from.hpp:201
auto subscribe(observer< Type, ObserverStrategy > &&observer)
Subscribes passed observer to emissions from this observable.
Definition subscribe.hpp:226