fixed the result computation using the stop token

Author: dietmarkuehl

include/beman/execution/detail/when_all.hpp

@@ -166,12 +166,12 @@ struct when_all_t {
         using value_types =
             typename ::beman::execution::detail::when_all_value_types<::beman::execution::detail::meta::combine<
                 ::beman::execution::
-                    value_types_of_t<Sender, Env, ::beman::execution::detail::type_list, ::std::type_identity_t>...>>::
+                    value_types_of_t<Sender, when_all_env<Env>, ::beman::execution::detail::type_list, ::std::type_identity_t>...>>::
                 type;
         using error_types = ::beman::execution::detail::meta::unique<::beman::execution::detail::meta::combine<
-            ::beman::execution::error_types_of_t<Sender, Env, error_comps>...>>;
+            ::beman::execution::error_types_of_t<Sender, when_all_env<Env>, error_comps>...>>;
         using stopped_types =
-            ::std::conditional_t<(false || ... || ::beman::execution::sends_stopped<Sender, Env>),
+            ::std::conditional_t<(false || ... || ::beman::execution::sends_stopped<Sender, when_all_env<Env>>),
                                  ::beman::execution::completion_signatures<::beman::execution::set_stopped_t()>,
                                  ::beman::execution::completion_signatures<>>;
         using type = ::beman::execution::detail::meta::combine<value_types, error_types, stopped_types>;

tests/beman/execution/exec-read-env.test.cpp

@@ -5,6 +5,7 @@
 #include <test/execution.hpp>
 #ifdef BEMAN_HAS_MODULES
 import beman.execution;
+import beman.execution.detail.join_env;
 #else
 #include <beman/execution/detail/read_env.hpp>
 #include <beman/execution/detail/common.hpp>
@@ -94,6 +95,7 @@ auto test_read_env_completions() -> void {
     test::use(r);
 
     test_std::sync_wait(test_std::read_env(test_std::get_stop_token));
+    test_std::sync_wait(test_std::when_all(test_std::read_env(test_std::get_stop_token)));
     test_std::sync_wait(test_std::when_all(test_std::read_env(test_std::get_scheduler)));
 }
 } // namespace