Coverting observable<T> to observable<list<T>>

[hasyimibhar]

What's the equivalent of RxJava's toList in RxCpp?

auto numbers = rxcpp::observable<>::range(1, 100);
numbers
    ./* convert rxcpp::observable<int> to rxcpp::observable<std::list<int>>> */
    .subscribe([](std::list<int> numbers)
    {
        /* do stuff */
    });

[kirkshoop]

that operator has not been added yet, so for now one would explicitly use reduce.

    rx::observable<>::range(1, 10).
        reduce(std::list<int>(),
            [](std::list<int>& o, int v){
                o.push_back(v);
                return std::move(o);
            },
            [](std::list<int>& o){
                return std::move(o);
            }).
        as_blocking().
        subscribe(
            [](std::list<int> ten){
                for(auto v : ten){
                    printf("%d\n", v);
                }
            });

[hasyimibhar]

Good enough for now. :)

[kirkshoop]

contributions welcome!