Function buffer

src/rpp/rpp/operators/buffer.hpp:111–114

* @brief Periodically gather emissions emitted by an original Observable into bundles and emit these bundles rather than emitting * the items one at a time * * @marble buffer { source observable : +-1-2-3-| operator "buffer(2)" : +---{1,2}-{3}-| } * * @details The resulting bundle is `std::vector ` of requested size. Actu

     * @see https://reactivex.io/documentation/operators/buffer.html
     */
    inline auto buffer(size_t count)
    {
        return details::buffer_t{count};
    }
} // namespace rpp::operators