{

public:

socket_recv_operation_impl(

socket& s,

void* buffer,

std::size_t byteCount) noexcept

: m_socket(s)

, m_buffer(buffer, byteCount)

{}

bool try_start(cppcoro::detail::win32_overlapped_operation_base& operation) noexcept;

void cancel(cppcoro::detail::win32_overlapped_operation_base& operation) noexcept;

private:

socket& m_socket;

cppcoro::detail::win32::wsabuf m_buffer;

: public cppcoro::detail::win32_overlapped_operation<socket_recv_operation>

{

public:

socket_recv_operation(

socket& s,

void* buffer,

std::size_t byteCount) noexcept

: m_impl(s, buffer, byteCount)

{}

private:

friend class cppcoro::detail::win32_overlapped_operation<socket_recv_operation>;

bool try_start() noexcept { return m_impl.try_start(*this); }

socket_recv_operation_impl m_impl;

: public cppcoro::detail::win32_overlapped_operation_cancellable<socket_recv_operation_cancellable>

{

public:

socket_recv_operation_cancellable(

socket& s,

void* buffer,

std::size_t byteCount,

cancellation_token&& ct) noexcept

: cppcoro::detail::win32_overlapped_operation_cancellable<socket_recv_operation_cancellable>(std::move(ct))

, m_impl(s, buffer, byteCount)

{}

private:

friend class cppcoro::detail::win32_overlapped_operation_cancellable<socket_recv_operation_cancellable>;

bool try_start() noexcept { return m_impl.try_start(*this); }

void cancel() noexcept { m_impl.cancel(*this); }

socket_recv_operation_impl m_impl;