run.h

Go to the documentation of this file.

#pragma once
 
#include "di/execution/concepts/sender.h"
#include "di/execution/query/get_sequence_cardinality.h"
#include "di/execution/sequence/sequence_sender.h"
#include "di/function/tag_invoke.h"
 
namespace di::execution {
namespace run_ns {
    struct Function {
        template<typename T>
        requires(concepts::TagInvocable<Function, T&>)
        auto operator()(T& resource) const {
            using R = meta::TagInvokeResult<Function, T&>;
            static_assert(concepts::Sender<R>, "run() customizations must return a SequenceSender.");
            static_assert(meta::SequenceCardinality<R> == 1,
                          "run() customizations must return a SequenceSender with cardinality 1.");
            return tag_invoke(*this, resource);
        }
    };
}

constexpr inline auto run = run_ns::Function {};
}
 
namespace di::concepts {
template<typename T>
concept AsyncResource = requires(T& resource) {
    { execution::run(resource) };
};
}