create.hpp

//                   ReactivePlusPlus library
//
//           Copyright Aleksey Loginov 2023 - 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/AlexInLog/ReactivePlusPlus
 
#pragma once
 
#include <rpp/sources/fwd.hpp>
 
#include <rpp/observables/observable.hpp>
 
namespace rpp::details
{
    template<constraint::decayed_type Type, constraint::on_subscribe<Type> OnSubscribe>
    struct create_strategy
    {
        using value_type                   = Type;
        using optimal_disposables_strategy = rpp::details::observables::default_disposables_strategy;
 
        RPP_NO_UNIQUE_ADDRESS OnSubscribe subscribe;
    };
} // namespace rpp::details
 
namespace rpp
{
    template<constraint::decayed_type Type, constraint::on_subscribe<Type> OnSubscribe>
    using create_observable = observable<Type, details::create_strategy<Type, OnSubscribe>>;
} // namespace rpp
 
namespace rpp::source
{
     * @see https://reactivex.io/documentation/operators/create.html
     */
    template<constraint::decayed_type Type, constraint::on_subscribe<Type> OnSubscribe>
    auto create(OnSubscribe&& on_subscribe)
    {
        return create_observable<Type, std::decay_t<OnSubscribe>>{std::forward<OnSubscribe>(on_subscribe)};
    }

     * @snippet create.cpp create with capture
     *
     * @ingroup creational_operators
     * @see https://reactivex.io/documentation/operators/create.html
     */
    template<typename OnSubscribe, constraint::decayed_type Type>
    auto create(OnSubscribe&& on_subscribe)
    {
        return create<Type>(std::forward<OnSubscribe>(on_subscribe));
    }
} // namespace rpp::source