Skip to content

Commit b5d083e

Browse files
committed
op_sender are standard senders
1 parent 565b2a2 commit b5d083e

1 file changed

Lines changed: 33 additions & 21 deletions

File tree

‎include/condy/senders.hpp‎

Lines changed: 33 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
#pragma once
77

88
#include "condy/concepts.hpp"
9+
#include "condy/execution.hpp"
910
#include "condy/op_states.hpp"
1011
#include <array>
1112
#include <stdexcept>
@@ -294,57 +295,68 @@ class [[nodiscard]] RangedLinkSenderImplBase {
294295
} // namespace detail
295296

296297
template <PrepFuncLike PrepFunc, CQEHandlerLike CQEHandler>
297-
using OpSender = detail::OpSenderImpl<PrepFunc, CQEHandler>;
298+
using OpSender =
299+
detail::StandardSender<detail::OpSenderImpl<PrepFunc, CQEHandler>>;
298300

299301
template <PrepFuncLike PrepFunc, CQEHandlerLike CQEHandler,
300302
typename MultiShotFunc>
301-
using MultiShotOpSender =
302-
detail::MultiShotOpSenderImpl<PrepFunc, CQEHandler, MultiShotFunc>;
303+
using MultiShotOpSender = detail::StandardSender<
304+
detail::MultiShotOpSenderImpl<PrepFunc, CQEHandler, MultiShotFunc>>;
303305

304306
template <PrepFuncLike PrepFunc, CQEHandlerLike CQEHandler, typename FreeFunc>
305-
using ZeroCopyOpSender =
306-
detail::ZeroCopyOpSenderImpl<PrepFunc, CQEHandler, FreeFunc>;
307+
using ZeroCopyOpSender = detail::StandardSender<
308+
detail::ZeroCopyOpSenderImpl<PrepFunc, CQEHandler, FreeFunc>>;
307309

308310
template <unsigned int Flags, typename Sender>
309-
using FlaggedOpSender = detail::FlaggedOpSenderImpl<Flags, Sender>;
311+
using FlaggedOpSender =
312+
detail::StandardSender<detail::FlaggedOpSenderImpl<Flags, Sender>>;
310313

311314
template <typename... Senders>
312-
using ParallelAllSender = detail::ParallelAllSenderImpl<Senders...>;
315+
using ParallelAllSender =
316+
detail::StandardSender<detail::ParallelAllSenderImpl<Senders...>>;
313317

314318
template <typename... Senders>
315-
using ParallelAnySender = detail::ParallelAnySenderImpl<Senders...>;
319+
using ParallelAnySender =
320+
detail::StandardSender<detail::ParallelAnySenderImpl<Senders...>>;
316321

317322
template <typename... Senders>
318-
using WhenAllSender = detail::WhenAllSenderImpl<Senders...>;
323+
using WhenAllSender =
324+
detail::StandardSender<detail::WhenAllSenderImpl<Senders...>>;
319325

320326
template <typename... Senders>
321-
using WhenAnySender = detail::WhenAnySenderImpl<Senders...>;
327+
using WhenAnySender =
328+
detail::StandardSender<detail::WhenAnySenderImpl<Senders...>>;
322329

323330
template <typename... Senders>
324-
using LinkSender = detail::LinkSenderImplBase<IOSQE_IO_LINK, Senders...>;
331+
using LinkSender = detail::StandardSender<
332+
detail::LinkSenderImplBase<IOSQE_IO_LINK, Senders...>>;
325333

326334
template <typename... Senders>
327-
using HardLinkSender =
328-
detail::LinkSenderImplBase<IOSQE_IO_HARDLINK, Senders...>;
335+
using HardLinkSender = detail::StandardSender<
336+
detail::LinkSenderImplBase<IOSQE_IO_HARDLINK, Senders...>>;
329337

330338
template <typename Sender>
331-
using RangedParallelAllSender = detail::RangedParallelAllSenderImpl<Sender>;
339+
using RangedParallelAllSender =
340+
detail::StandardSender<detail::RangedParallelAllSenderImpl<Sender>>;
332341

333342
template <typename Sender>
334-
using RangedParallelAnySender = detail::RangedParallelAnySenderImpl<Sender>;
343+
using RangedParallelAnySender =
344+
detail::StandardSender<detail::RangedParallelAnySenderImpl<Sender>>;
335345

336346
template <typename Sender>
337-
using RangedWhenAllSender = detail::RangedWhenAllSenderImpl<Sender>;
347+
using RangedWhenAllSender =
348+
detail::StandardSender<detail::RangedWhenAllSenderImpl<Sender>>;
338349

339350
template <typename Sender>
340-
using RangedWhenAnySender = detail::RangedWhenAnySenderImpl<Sender>;
351+
using RangedWhenAnySender =
352+
detail::StandardSender<detail::RangedWhenAnySenderImpl<Sender>>;
341353

342354
template <typename Sender>
343-
using RangedLinkSender =
344-
detail::RangedLinkSenderImplBase<IOSQE_IO_LINK, Sender>;
355+
using RangedLinkSender = detail::StandardSender<
356+
detail::RangedLinkSenderImplBase<IOSQE_IO_LINK, Sender>>;
345357

346358
template <typename Sender>
347-
using RangedHardLinkSender =
348-
detail::RangedLinkSenderImplBase<IOSQE_IO_HARDLINK, Sender>;
359+
using RangedHardLinkSender = detail::StandardSender<
360+
detail::RangedLinkSenderImplBase<IOSQE_IO_HARDLINK, Sender>>;
349361

350362
} // namespace condy

0 commit comments

Comments
 (0)