ref_count.hpp

#pragma once
 
#include <rpp/observables/connectable_observable.hpp>
 
namespace rpp::operators::details
{
    struct ref_count_t
    {
        template<rpp::constraint::observable OriginalObservable, rpp::constraint::subject Subject>
        auto operator()(const connectable_observable<OriginalObservable, Subject>& observable) const
        {
            return observable.ref_count();
        }
    };
} // namespace rpp::operators::details
 
namespace rpp::operators
{
    inline auto ref_count()
    {
        return rpp::operators::details::ref_count_t{};
    }
} // namespace rpp::operators