worker.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/victimsnino/ReactivePlusPlus
//
 
#pragma once
 
#include <rpp/schedulers/fwd.hpp>
 
#include <rpp/defs.hpp>
#include <rpp/disposables/disposable_wrapper.hpp>
#include <rpp/utils/constraints.hpp>
 
namespace rpp::schedulers
{
    template<rpp::schedulers::constraint::strategy Strategy>
    class worker
    {
    public:
        template<typename... Args>
            requires (!rpp::constraint::variadic_decayed_same_as<worker<Strategy>, Args...> && rpp::constraint::is_constructible_from<Strategy, Args && ...>)
        explicit worker(Args&&... args)
            : m_strategy(std::forward<Args>(args)...)
        {
        }
 
        worker(const worker&)     = default;
        worker(worker&&) noexcept = default;
 
        template<rpp::schedulers::constraint::schedulable_handler Handler, typename... Args, constraint::schedulable_fn<Handler, Args...> Fn>
        void schedule(Fn&& fn, Handler&& handler, Args&&... args) const
        {
            schedule(duration{}, std::forward<Fn>(fn), std::forward<Handler>(handler), std::forward<Args>(args)...);
        }
 
        template<rpp::schedulers::constraint::schedulable_handler Handler, typename... Args, constraint::schedulable_fn<Handler, Args...> Fn>
        void schedule(const duration delay, Fn&& fn, Handler&& handler, Args&&... args) const
        {
            if constexpr (constraint::defer_for_strategy<Strategy>)
                m_strategy.defer_for(delay, std::forward<Fn>(fn), std::forward<Handler>(handler), std::forward<Args>(args)...);
            else
                schedule(now() + delay, std::forward<Fn>(fn), std::forward<Handler>(handler), std::forward<Args>(args)...);
        }
 
        template<rpp::schedulers::constraint::schedulable_handler Handler, typename... Args, constraint::schedulable_fn<Handler, Args...> Fn>
        void schedule(const time_point tp, Fn&& fn, Handler&& handler, Args&&... args) const
        {
            if constexpr (constraint::defer_to_strategy<Strategy>)
                m_strategy.defer_to(tp, std::forward<Fn>(fn), std::forward<Handler>(handler), std::forward<Args>(args)...);
            else
                schedule(tp - now(), std::forward<Fn>(fn), std::forward<Handler>(handler), std::forward<Args>(args)...);
        }
 
        static rpp::schedulers::time_point now() { return Strategy::now(); }
 
    private:
        RPP_NO_UNIQUE_ADDRESS Strategy m_strategy;
    };
} // namespace rpp::schedulers