Merge pull request #1579 from ericniebler/write-env-and-unstoppable

add `write_env` and `unstoppable` sender adaptors to `stdexec::`

Author: ericniebler

examples/benchmark/asio_thread_pool.cpp

@@ -45,7 +45,7 @@ struct RunThread {
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       while (scheds) {
         stdexec::start_detached(
           stdexec::schedule(scheduler) | stdexec::then([&] {

examples/benchmark/common.hpp

@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-#include <exec/env.hpp>
 #include <exec/__detail/__numa.hpp>
 #include <exec/static_thread_pool.hpp>
 

examples/benchmark/static_thread_pool.cpp

@@ -47,7 +47,7 @@ struct RunThread {
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       while (scheds) {
         stdexec::start_detached(
           stdexec::schedule(scheduler) | stdexec::then([&] {

examples/benchmark/static_thread_pool_bulk_enqueue.cpp

@@ -42,10 +42,10 @@ struct RunThread {
 #  ifndef STDEXEC_NO_MONOTONIC_BUFFER_RESOURCE
       pmr::monotonic_buffer_resource rsrc{buffer.data(), buffer.size()};
       pmr::polymorphic_allocator<char> alloc{&rsrc};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::schedule_all(pool, std::views::iota(start, end))
-                   | exec::ignore_all_values() | exec::write_env(env);
+                   | exec::ignore_all_values() | stdexec::write_env(env);
 #  else
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::schedule_all(pool, std::views::iota(start, end))

examples/benchmark/static_thread_pool_bulk_enqueue_nested.cpp

@@ -43,10 +43,10 @@ struct RunThread {
 #  ifndef STDEXEC_NO_MONOTONIC_BUFFER_RESOURCE
       pmr::monotonic_buffer_resource rsrc{buffer.data(), buffer.size()};
       pmr::polymorphic_allocator<char> alloc{&rsrc};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::iterate(std::views::iota(start, end)) | exec::ignore_all_values()
-                   | exec::write_env(env);
+                   | stdexec::write_env(env);
 #  else
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::iterate(std::views::iota(start, end)) | exec::ignore_all_values();

examples/benchmark/static_thread_pool_nested.cpp

@@ -45,7 +45,7 @@ struct RunThread {
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       stdexec::sync_wait(stdexec::schedule(scheduler) | stdexec::then([&] {
                            auto nested_scheduler = pool.get_scheduler();
                            while (scheds) {

examples/benchmark/static_thread_pool_nested_old.cpp

@@ -45,7 +45,7 @@ struct RunThread {
       auto [start, end] = exec_old::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       stdexec::sync_wait(stdexec::schedule(scheduler) | stdexec::then([&] {
                            while (scheds) {
                              stdexec::start_detached(

examples/benchmark/static_thread_pool_old.cpp

@@ -47,7 +47,7 @@ struct RunThread {
       auto [start, end] = exec_old::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       while (scheds) {
         stdexec::start_detached(
           stdexec::schedule(scheduler) | stdexec::then([&] {

examples/benchmark/taskflow_thread_pool.cpp

@@ -45,7 +45,7 @@ struct RunThread {
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       while (scheds) {
         stdexec::start_detached(
           stdexec::schedule(scheduler) | stdexec::then([&] {

examples/benchmark/tbb_thread_pool.cpp

@@ -45,7 +45,7 @@ struct RunThread {
       auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
-      auto env = exec::make_env(stdexec::prop{stdexec::get_allocator, alloc});
+      auto env = stdexec::prop{stdexec::get_allocator, alloc};
       while (scheds) {
         stdexec::start_detached(
           stdexec::schedule(scheduler) | stdexec::then([&] {