rxcpp

gistfile1.cpp

int main(int argc, char** argv)
{
    auto get_nums = [](){return rx::observable<>::from<int>(
        1,2,3,4,5,6,7,8,9,10
    );};

    auto hello_str = [&](){return get_nums().map([](int n){
        return std::to_string(n).c_str();
    }).as_dynamic();};

    hello_str().subscribe(rxu::println(std::cout));

    return 0;
}