from.cpp

#include <rpp/rpp.hpp>
 
#include <iostream>
 
int main() // NOLINT(bugprone-exception-escape)
{
    {
        std::vector<int> vals{1, 2, 3};
        rpp::source::from_iterable(vals).subscribe([](int v) { std::cout << v << " "; });
    }
 
    {
        std::vector<int> vals{1, 2, 3};
        rpp::source::from_iterable<rpp::memory_model::use_shared>(vals).subscribe([](int v) { std::cout << v << " "; });
    }
 
    {
        std::vector<int> vals{1, 2, 3};
        rpp::source::from_iterable(vals, rpp::schedulers::immediate{}).subscribe([](int v) { std::cout << v << " "; });
        rpp::source::from_iterable(vals, rpp::schedulers::current_thread{}).subscribe([](int v) { std::cout << v << " "; });
    }
 
    {
        rpp::source::from_callable([]() { return 49; }).subscribe([](int v) { std::cout << v << " "; });
        // Output: 49
    }
    return 0;
}