Method on_next

src/rpp/rpp/operators/take.hpp:31–41

        template<typename T>
        void on_next(T&& v) const
        {
            if (count > 0)
            {
                --count;
                observer.on_next(std::forward<T>(v));
            }

            if (count == 0)
                observer.on_completed();
        }

        void on_error(const std::exception_ptr& err) const { observer.on_error(err); }