Function main

src/examples/rpp/doxygen/create.cpp:9–27

 **/

int main() // NOLINT(bugprone-exception-escape)
{
    //! [create]
    rpp::source::create<int>([](const auto& sub) {
        sub.on_next(42);
    })
        .subscribe([](int v) { std::cout << v << std::endl; });
    // Output: 42
    //! [create]

    //! [create with capture]
    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
    //! [create with capture]
}