interface_observable.hpp

//                  ReactivePlusPlus library
//
//          Copyright Aleksey Loginov 2022 - present.
// Distributed under the Boost Software License, Version 1.0.
//    (See accompanying file LICENSE_1_0.txt or copy at
//          https://www.boost.org/LICENSE_1_0.txt)
//
// Project home: https://github.com/victimsnino/ReactivePlusPlus
//
 
#pragma once
 
#include <rpp/defs.hpp>                             // RPP_EMPTY_BASES
#include <rpp/observables/blocking_observable.hpp>  // as_blocking
#include <rpp/observables/constraints.hpp>          // own constraints
#include <rpp/observables/fwd.hpp>                  // own forwarding
#include <rpp/operators/fwd.hpp>                    // forwarding of member_overaloads
#include <rpp/utils/function_traits.hpp>            // decayed_invoke_result_t
 
#include <type_traits>
 
namespace rpp::details
{
template<typename T, typename TObservable>
concept op_fn = constraint::observable<utils::decayed_invoke_result_t<T, TObservable>>;
} // namespace rpp::details
 
namespace rpp
{
template<constraint::decayed_type Type, typename SpecificObservable>
struct RPP_EMPTY_BASES interface_observable
    : public details::typed_observable_tag<Type>
    , details::member_overload<Type, SpecificObservable, details::buffer_tag>
    , details::member_overload<Type, SpecificObservable, details::combine_latest_tag>
    , details::member_overload<Type, SpecificObservable, details::concat_tag>
    , details::member_overload<Type, SpecificObservable, details::delay_tag>
    , details::member_overload<Type, SpecificObservable, details::debounce_tag>
    , details::member_overload<Type, SpecificObservable, details::distinct_until_changed_tag>
    , details::member_overload<Type, SpecificObservable, details::do_tag>
    , details::member_overload<Type, SpecificObservable, details::filter_tag>
    , details::member_overload<Type, SpecificObservable, details::first_tag>
    , details::member_overload<Type, SpecificObservable, details::flat_map_tag>
    , details::member_overload<Type, SpecificObservable, details::group_by_tag>
    , details::member_overload<Type, SpecificObservable, details::last_tag>
    , details::member_overload<Type, SpecificObservable, details::lift_tag>
    , details::member_overload<Type, SpecificObservable, details::map_tag>
    , details::member_overload<Type, SpecificObservable, details::merge_tag>
    , details::member_overload<Type, SpecificObservable, details::multicast_tag>
    , details::member_overload<Type, SpecificObservable, details::observe_on_tag>
    , details::member_overload<Type, SpecificObservable, details::on_error_resume_next_tag>
    , details::member_overload<Type, SpecificObservable, details::publish_tag>
    , details::member_overload<Type, SpecificObservable, details::reduce_tag>
    , details::member_overload<Type, SpecificObservable, details::repeat_tag>
    , details::member_overload<Type, SpecificObservable, details::sample_tag>
    , details::member_overload<Type, SpecificObservable, details::scan_tag>
    , details::member_overload<Type, SpecificObservable, details::skip_tag>
    , details::member_overload<Type, SpecificObservable, details::start_with_tag>
    , details::member_overload<Type, SpecificObservable, details::subscribe_on_tag>
    , details::member_overload<Type, SpecificObservable, details::subscribe_tag>
    , details::member_overload<Type, SpecificObservable, details::switch_map_tag>
    , details::member_overload<Type, SpecificObservable, details::switch_on_next_tag>
    , details::member_overload<Type, SpecificObservable, details::take_last_tag>
    , details::member_overload<Type, SpecificObservable, details::take_tag>
    , details::member_overload<Type, SpecificObservable, details::take_until_tag>
    , details::member_overload<Type, SpecificObservable, details::take_while_tag>
    , details::member_overload<Type, SpecificObservable, details::timeout_tag>
    , details::member_overload<Type, SpecificObservable, details::window_tag>
    , details::member_overload<Type, SpecificObservable, details::with_latest_from_tag>
{
public:
 
    template<details::op_fn<SpecificObservable> OperatorFn>
    auto op(OperatorFn&& fn) const &
    {
        return fn(CastThis());
    }
 
    template<details::op_fn<SpecificObservable> OperatorFn>
    auto op(OperatorFn&& fn) &&
    {
        return fn(MoveThis());
    }
 
    auto as_blocking() const &
    {
        return blocking_observable{ CastThis ()};
    }
 
    auto as_blocking()&&
    {
        return blocking_observable{ MoveThis() };
    }
    
private:
    const SpecificObservable& CastThis() const
    {
        return *static_cast<const SpecificObservable*>(this);
    }
 
    SpecificObservable&& MoveThis()
    {
        return std::move(*static_cast<SpecificObservable*>(this));
    }
};
} // namespace rpp