exec::inline_scheduler is an alias for stdexec::__inln::__scheduler

Author: ericniebler

include/exec/inline_scheduler.hpp

@@ -22,52 +22,5 @@
 namespace exec {
   // A simple scheduler that executes its continuation inline, on the
   // thread of the caller of start().
-  struct inline_scheduler {
-    template <class R_>
-    struct __op {
-      using R = stdexec::__t<R_>;
-      STDEXEC_NO_UNIQUE_ADDRESS R rec_;
-
-      friend void tag_invoke(stdexec::start_t, __op& op) noexcept {
-        stdexec::set_value((R&&) op.rec_);
-      }
-    };
-
-    struct __sender {
-      using is_sender = void;
-      using completion_signatures = stdexec::completion_signatures<stdexec::set_value_t()>;
-
-      template <class R>
-      friend auto tag_invoke(stdexec::connect_t, __sender, R&& rec) //
-        noexcept(stdexec::__nothrow_constructible_from<stdexec::__decay_t<R>, R>)
-          -> __op<stdexec::__x<stdexec::__decay_t<R>>> {
-        return {(R&&) rec};
-      }
-
-      struct __env {
-        friend inline_scheduler
-          tag_invoke(stdexec::get_completion_scheduler_t<stdexec::set_value_t>, const __env&) //
-          noexcept {
-          return {};
-        }
-      };
-
-      friend __env tag_invoke(stdexec::get_env_t, const __sender&) noexcept {
-        return {};
-      }
-    };
-
-    STDEXEC_DETAIL_CUDACC_HOST_DEVICE //
-      friend __sender
-      tag_invoke(stdexec::schedule_t, const inline_scheduler&) noexcept {
-      return {};
-    }
-
-    friend stdexec::forward_progress_guarantee
-      tag_invoke(stdexec::get_forward_progress_guarantee_t, const inline_scheduler&) noexcept {
-      return stdexec::forward_progress_guarantee::weakly_parallel;
-    }
-
-    bool operator==(const inline_scheduler&) const noexcept = default;
-  };
+  using inline_scheduler = stdexec::__inln::__scheduler;
 }

include/stdexec/execution.hpp

@@ -2503,6 +2503,8 @@ namespace stdexec {
   inline constexpr __submit_t __submit{};
 
   namespace __inln {
+    struct __scheduler;
+
     template <class _Receiver>
     struct __op : __immovable {
       _Receiver __recv_;
@@ -2513,7 +2515,8 @@ namespace stdexec {
     };
 
     struct __schedule_t {
-      static auto get_env(__ignore) noexcept;
+      static auto get_env(__ignore) noexcept
+        -> __env::__prop<get_completion_scheduler_t<set_value_t>, __scheduler>;
 
       using __compl_sigs = stdexec::completion_signatures<set_value_t()>;
       static __compl_sigs get_completion_signatures(__ignore, __ignore);
@@ -2529,17 +2532,23 @@ namespace stdexec {
       using __t = __scheduler;
       using __id = __scheduler;
 
-      friend auto tag_invoke(schedule_t, __scheduler) {
+      STDEXEC_DETAIL_CUDACC_HOST_DEVICE //
+        friend auto
+        tag_invoke(schedule_t, __scheduler) {
         return make_sender_expr<__schedule_t>();
       }
 
+      friend forward_progress_guarantee
+        tag_invoke(get_forward_progress_guarantee_t, __scheduler) noexcept {
+        return forward_progress_guarantee::weakly_parallel;
+      }
+
       bool operator==(const __scheduler&) const noexcept = default;
     };
 
-    inline auto __schedule_t::get_env(__ignore) noexcept {
-      return __env::__env_fn{[](get_completion_scheduler_t<set_value_t>) noexcept {
-        return __scheduler{};
-      }};
+    inline auto __schedule_t::get_env(__ignore) noexcept
+      -> __env::__prop<get_completion_scheduler_t<set_value_t>, __scheduler> {
+      return __mkprop(get_completion_scheduler<set_value_t>, __scheduler{});
     }
   }