subscribe_on.cpp

#include <rpp/rpp.hpp>
#include <iostream>
 
int main()
{
    std::cout << std::this_thread::get_id() << std::endl;
    rpp::source::create<int>([](const auto& sub)
            {
                std::cout << "on_subscribe thread " << std::this_thread::get_id() << std::endl;
                sub.on_next(1);
                sub.on_completed();
            })
            .subscribe_on(rpp::schedulers::new_thread{})
            .as_blocking()
            .subscribe([](int v) { std::cout << "[" << std::this_thread::get_id() << "] : " << v << "\n"; });
    // Template for output:
    // TH1
    // on_subscribe thread TH2
    // [TH2]: 1
    return 0;
}