Move test::inline_scheduler to namespace beman::execution

.gitignore

@@ -35,6 +35,7 @@ CMakeUserPresets.json
 *.app
 
 build
+cmake-build-*
 .DS_store
 .vs
 .cache

include/beman/execution/detail/inline_scheduler.hpp

@@ -0,0 +1,79 @@
+// include/beman/execution/detail/inline_scheduler.hpp            -*-C++-*-
+// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
+
+#ifndef INCLUDED_BEMAN_DETAIL_EXECUTION_INLINE_SCHEDULER
+#define INCLUDED_BEMAN_DETAIL_EXECUTION_INLINE_SCHEDULER
+
+// ----------------------------------------------------------------------------
+#include <beman/execution/detail/common.hpp>
+#ifdef BEMAN_HAS_IMPORT_STD
+import std;
+#else
+#include <type_traits>
+#include <utility>
+#endif
+#ifdef BEMAN_HAS_MODULES
+import beman.execution.detail.get_completion_scheduler;
+import beman.execution.detail.sender;
+import beman.execution.detail.receiver;
+import beman.execution.detail.set_value;
+import beman.execution.detail.operation_state;
+import beman.execution.detail.scheduler;
+import beman.execution.detail.scheduler_t;
+import beman.execution.detail.completion_signatures;
+#else
+#include <beman/execution/detail/get_completion_scheduler.hpp>
+#include <beman/execution/detail/sender.hpp>
+#include <beman/execution/detail/receiver.hpp>
+#include <beman/execution/detail/set_value.hpp>
+#include <beman/execution/detail/operation_state.hpp>
+#include <beman/execution/detail/scheduler.hpp>
+#include <beman/execution/detail/completion_signatures.hpp>
+#endif
+
+namespace beman::execution {
+struct inline_scheduler {
+    using scheduler_concept = ::beman::execution::scheduler_t;
+
+    struct env {
+        static auto
+        query(const ::beman::execution::get_completion_scheduler_t<::beman::execution::set_value_t>&) noexcept
+            -> inline_scheduler {
+            return {};
+        }
+    };
+
+    template <::beman::execution::receiver Rcvr>
+    struct state {
+        using operation_state_concept = ::beman::execution::operation_state_t;
+        ::std::remove_cvref_t<Rcvr> rcvr;
+        auto                        start() & noexcept -> void { ::beman::execution::set_value(::std::move(rcvr)); }
+    };
+
+    struct sender {
+        using sender_concept        = ::beman::execution::sender_t;
+        using completion_signatures = ::beman::execution::completion_signatures<::beman::execution::set_value_t()>;
+
+        static constexpr auto get_env() noexcept -> env { return {}; }
+
+        template <typename, typename...>
+        static consteval auto get_completion_signatures() noexcept -> completion_signatures {
+            return {};
+        }
+
+        template <::beman::execution::receiver Rcvr>
+        auto connect(Rcvr&& receiver) noexcept(::std::is_nothrow_constructible_v<::std::remove_cvref_t<Rcvr>, Rcvr>)
+            -> state<Rcvr> {
+            return {::std::forward<Rcvr>(receiver)};
+        }
+    };
+
+    static constexpr auto schedule() noexcept -> sender { return {}; }
+
+    auto operator==(const inline_scheduler&) const -> bool = default;
+};
+} // namespace beman::execution
+
+// ----------------------------------------------------------------------------
+
+#endif // INCLUDED_BEMAN_DETAIL_EXECUTION_INLINE_SCHEDULER

src/beman/execution/CMakeLists.txt

@@ -97,6 +97,7 @@ target_sources(
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/impls_for.hpp
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/indices_for.hpp
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/indirect_meta_apply.hpp
+                ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/inline_scheduler.hpp
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/inplace_stop_source.hpp
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/into_variant.hpp
                 ${PROJECT_SOURCE_DIR}/include/beman/execution/detail/intrusive_stack.hpp
@@ -282,6 +283,7 @@ if(BEMAN_USE_MODULES)
                     impls_for.cppm
                     indices_for.cppm
                     indirect_meta_apply.cppm
+                    inline_scheduler.cppm
                     inplace_stop_source.cppm
                     into_variant.cppm
                     intrusive_stack.cppm

src/beman/execution/execution.cppm

@@ -77,6 +77,7 @@ import beman.execution.detail.when_all;
 import beman.execution.detail.when_all_with_variant;
 export import beman.execution.detail.with_awaitable_senders; // [exec.with.awaitable.senders]
 import beman.execution.detail.write_env;
+import beman.execution.detail.inline_scheduler;
 
 // [stoptoken.concepts], stop token concepts
 export import beman.execution.detail.stoppable_token;
@@ -254,6 +255,9 @@ export using ::beman::execution::counting_scope;
 export using ::beman::execution::spawn;
 export using ::beman::execution::spawn_future;
 
+// [exec.inline.scheduler]
+export using ::beman::execution::inline_scheduler;
+
 #if 0
 namespace detail {
 export using ::beman::execution::detail::await_result_type;

src/beman/execution/inline_scheduler.cppm

@@ -0,0 +1,11 @@
+module;
+// src/beman/execution/inline_scheduler.cppm                       -*-C++-*-
+// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
+
+#include <beman/execution/detail/inline_scheduler.hpp>
+
+export module beman.execution.detail.inline_scheduler;
+
+namespace beman::execution {
+export using beman::execution::inline_scheduler;
+} // namespace beman::execution

tests/beman/execution/exec-scope-counting.test.cpp

@@ -4,7 +4,6 @@
 #include <concepts>
 #include <tuple>
 #include <type_traits>
-#include <test/inline_scheduler.hpp>
 #include <test/execution.hpp>
 #ifdef BEMAN_HAS_MODULES
 import beman.execution;
@@ -13,6 +12,7 @@ import beman.execution;
 #include <beman/execution/detail/sender.hpp>
 #include <beman/execution/detail/just.hpp>
 #include <beman/execution/detail/sync_wait.hpp>
+#include <beman/execution/detail/inline_scheduler.hpp>
 #endif
 
 // ----------------------------------------------------------------------------
@@ -45,7 +45,7 @@ struct join_receiver {
     using receiver_concept = test_std::receiver_t;
 
     struct env {
-        auto query(const test_std::get_scheduler_t&) const noexcept -> test::inline_scheduler { return {}; }
+        auto query(const test_std::get_scheduler_t&) const noexcept -> test_std::inline_scheduler { return {}; }
     };
 
     bool& called;

tests/beman/execution/exec-scope-simple-counting.test.cpp

@@ -4,7 +4,6 @@
 #include <concepts>
 #include <tuple>
 #include <type_traits>
-#include <test/inline_scheduler.hpp>
 #include <test/execution.hpp>
 #ifdef BEMAN_HAS_MODULES
 import beman.execution;
@@ -13,6 +12,7 @@ import beman.execution;
 #include <beman/execution/detail/sender.hpp>
 #include <beman/execution/detail/just.hpp>
 #include <beman/execution/detail/sync_wait.hpp>
+#include <beman/execution/detail/inline_scheduler.hpp>
 #endif
 
 // ----------------------------------------------------------------------------
@@ -42,7 +42,7 @@ struct join_receiver {
     using receiver_concept = test_std::receiver_t;
 
     struct env {
-        auto query(const test_std::get_scheduler_t&) const noexcept -> test::inline_scheduler { return {}; }
+        auto query(const test_std::get_scheduler_t&) const noexcept -> test_std::inline_scheduler { return {}; }
     };
 
     bool& called;