create.cpp

#include <rpp/rpp.hpp>
 
#include <iostream>
 
int main()
{
    rpp::source::create<int>([](const auto& sub)
            {
                sub.on_next(42);
            })
            .subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 42
 
    rpp::source::create([](const rpp::dynamic_subscriber<int>& sub)
            {
                sub.on_next(42);
            })
            .subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 42
 
    int                                        val = 42;
    rpp::source::create<int>([val](const auto& sub)
            {
                sub.on_next(val);
            })
            .subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 42
}