execute.h

Go to the documentation of this file.

#pragma once
 
#include "di/container/allocator/allocator.h"
#include "di/execution/algorithm/start_detached.h"
#include "di/execution/algorithm/then.h"
#include "di/execution/concepts/scheduler.h"
#include "di/execution/interface/schedule.h"
#include "di/execution/sequence/sequence_sender.h"
#include "di/function/invoke.h"
#include "di/function/tag_invoke.h"
#include "di/meta/util.h"
#include "di/platform/prelude.h"
 
namespace di::execution {
namespace execute_ns {
    struct Function {
        template<concepts::Scheduler Sched, concepts::MovableValue Fun, concepts::Allocator Alloc = DefaultAllocator>
        requires(concepts::Invocable<Fun>)
        auto operator()(Sched&& scheduler, Fun&& function, Alloc&& allocator = {}) const {
            if constexpr (concepts::TagInvocable<Function, Sched, Fun, Alloc>) {
                return function::tag_invoke(*this, util::forward<Sched>(scheduler), util::forward<Fun>(function),
                                            util::forward<Alloc>(allocator));
            } else {
                return start_detached(then(schedule(scheduler), util::forward<Fun>(function)),
                                      util::forward<Alloc>(allocator));
            }
        }
    };
}

constexpr inline auto execute = execute_ns::Function {};
}