Implement HPX Future-Sender Bridge (P2300 interoperability)

libs/core/execution/CMakeLists.txt

@@ -15,9 +15,11 @@ set(execution_headers
     hpx/execution/algorithms/detail/predicates.hpp
     hpx/execution/algorithms/detail/single_result.hpp
     hpx/execution/algorithms/detail/sync_wait_domain.hpp
+    hpx/execution/algorithms/future_sender.hpp
     hpx/execution/algorithms/keep_future.hpp
     hpx/execution/algorithms/make_future.hpp
     hpx/execution/algorithms/run_loop.hpp
+    hpx/execution/algorithms/sender_future.hpp
     hpx/execution/algorithms/sync_wait.hpp
     hpx/execution/algorithms/when_all.hpp
     hpx/execution/algorithms/when_all_vector.hpp

libs/core/execution/include/hpx/execution/algorithms/as_sender.hpp

@@ -9,6 +9,7 @@
 
 #include <hpx/assert.hpp>
 #include <hpx/execution/algorithms/detail/partial_algorithm.hpp>
+#include <hpx/execution/algorithms/future_sender.hpp>
 #include <hpx/modules/concepts.hpp>
 #include <hpx/modules/errors.hpp>
 #include <hpx/modules/execution_base.hpp>
@@ -146,93 +147,6 @@ namespace hpx::execution::experimental { namespace detail {
                 hpx::execution::experimental::set_error_t(std::exception_ptr)>;
     };
 
-    HPX_CXX_CORE_EXPORT template <typename Future>
-    struct as_sender_sender;
-
-    template <typename T>
-    struct as_sender_sender<hpx::future<T>>
-      : public as_sender_sender_base<hpx::future<T>>
-    {
-        using sender_concept = hpx::execution::experimental::sender_t;
-        using future_type = hpx::future<T>;
-        using base_type = as_sender_sender_base<hpx::future<T>>;
-        using base_type::future_;
-
-        template <typename Future>
-            requires(!std::is_same_v<std::decay_t<Future>, as_sender_sender>)
-        explicit as_sender_sender(Future&& future)
-          : base_type{HPX_FORWARD(Future, future)}
-        {
-        }
-
-        as_sender_sender(as_sender_sender&&) = default;
-        as_sender_sender& operator=(as_sender_sender&&) = default;
-        as_sender_sender(as_sender_sender const&) = delete;
-        as_sender_sender& operator=(as_sender_sender const&) = delete;
-
-        template <typename Self, typename... Env>
-        static consteval auto get_completion_signatures() noexcept ->
-            typename base_type::completion_signatures
-        {
-            return {};
-        }
-
-        template <typename Receiver>
-        auto connect(Receiver&& receiver) &&
-        {
-            return as_sender_operation_state<Receiver, future_type>{
-                HPX_FORWARD(Receiver, receiver), HPX_MOVE(future_)};
-        }
-    };
-}}    // namespace hpx::execution::experimental::detail
-
-namespace hpx::execution::experimental { namespace detail {
-    template <typename T>
-    struct as_sender_sender<hpx::shared_future<T>>
-      : as_sender_sender_base<hpx::shared_future<T>>
-    {
-        using sender_concept = hpx::execution::experimental::sender_t;
-        using future_type = hpx::shared_future<T>;
-        using base_type = as_sender_sender_base<hpx::shared_future<T>>;
-        using base_type::future_;
-
-        template <typename Future>
-            requires(!std::is_same_v<std::decay_t<Future>, as_sender_sender>)
-        explicit as_sender_sender(Future&& future)
-          : base_type{HPX_FORWARD(Future, future)}
-        {
-        }
-
-        as_sender_sender(as_sender_sender&&) = default;
-        as_sender_sender& operator=(as_sender_sender&&) = default;
-        as_sender_sender(as_sender_sender const&) = default;
-        as_sender_sender& operator=(as_sender_sender const&) = default;
-
-        template <typename Self, typename... Env>
-        static consteval auto get_completion_signatures() noexcept ->
-            typename base_type::completion_signatures
-        {
-            return {};
-        }
-
-        template <typename Receiver>
-        auto connect(Receiver&& receiver) &&
-        {
-            return as_sender_operation_state<Receiver, future_type>{
-                HPX_FORWARD(Receiver, receiver), HPX_MOVE(future_)};
-        }
-
-        template <typename Receiver>
-        auto connect(Receiver&& receiver) &
-        {
-            return as_sender_operation_state<Receiver, future_type>{
-                HPX_FORWARD(Receiver, receiver), future_};
-        }
-    };
-}}    // namespace hpx::execution::experimental::detail
-
-namespace hpx::execution::experimental { namespace detail {
-
     ///////////////////////////////////////////////////////////////////////
     // Scheduler-aware sender wrapper.
     //
@@ -343,8 +257,8 @@ namespace hpx::execution::experimental {
         // clang-format on
         constexpr HPX_FORCEINLINE auto operator()(Future&& future) const
         {
-            return detail::as_sender_sender<std::decay_t<Future>>(
-                HPX_FORWARD(Future, future));
+            return detail::future_sender<std::decay_t<Future>>{
+                HPX_FORWARD(Future, future)};
         }
 
         // Scheduler-aware overload: wraps the future into a sender whose
@@ -356,9 +270,9 @@ namespace hpx::execution::experimental {
         constexpr HPX_FORCEINLINE auto operator()(
             Future&& future, Scheduler&& scheduler) const
         {
-            return detail::as_sender_sender_with_scheduler<std::decay_t<Future>,
-                std::decay_t<Scheduler>>(
-                HPX_FORWARD(Future, future), HPX_FORWARD(Scheduler, scheduler));
+            return detail::future_sender_with_scheduler<std::decay_t<Future>,
+                std::decay_t<Scheduler>>{
+                HPX_FORWARD(Future, future), HPX_FORWARD(Scheduler, scheduler)};
         }
 
         constexpr HPX_FORCEINLINE auto operator()() const