async_write_some.h

Go to the documentation of this file.

#pragma once
 
#include "di/execution/concepts/scheduler.h"
#include "di/execution/concepts/sender_of.h"
#include "di/execution/receiver/set_value.h"
#include "di/execution/types/prelude.h"
#include "di/function/tag_invoke.h"
#include "di/meta/callable.h"
#include "di/types/integers.h"
#include "di/types/prelude.h"
#include "di/util/reference_wrapper.h"
 
namespace di::execution {
namespace async_write_some_ns {
    struct Function {
        template<typename File>
        requires(concepts::TagInvocable<Function, File, Span<Byte const>, Optional<u64>>)
        auto operator()(File&& handle, Span<Byte const> buffer, Optional<u64> offset = {}) const
            -> concepts::SenderOf<SetValue(usize)> auto {
            return function::tag_invoke(*this, util::forward<File>(handle), buffer, offset);
        }
 
        template<typename File>
        requires(concepts::TagInvocable<Function, File&, Span<Byte const>, Optional<u64>>)
        auto operator()(util::ReferenceWrapper<File> handle, Span<Byte const> buffer, Optional<u64> offset = {}) const {
            return function::tag_invoke(*this, handle.get(), buffer, offset);
        }
    };
}
 
constexpr inline auto async_write_some = async_write_some_ns::Function {};
}
 
namespace di::concepts {
template<typename T>
concept AsyncWritable = concepts::Callable<execution::async_write_some_ns::Function, T&, vocab::Span<byte const>>;
}