Delete deprecated headers

This diff removes the following deprecated headers: - `<unifex/execute.hpp>` (use `spawn_detached()`) - `<unifex/ready_done_sender.hpp>` (use `just_done()`) - `<unifex/submit.hpp>` (use `spawn_detached()`)` - `<unifex/via.hpp>` (use `typed_via()`) - `<unifex/via_stream.pp>` (use `typed_via_stream()`)
facebookexperimental · Jun 12, 2023 · 5daf47f · 5daf47f
1 parent e3e8fc0
commit 5daf47f
Show file tree

Hide file tree

Showing 20 changed files with 21 additions and 1,142 deletions.
diff --git a/examples/CMakeLists.txt b/examples/CMakeLists.txt
@@ -14,7 +14,6 @@ endforeach()
 
 if(CXX_MEMORY_RESOURCE_HAVE_PMR)
   target_link_libraries(any_unique PUBLIC std::memory_resource)
-  target_link_libraries(submit_allocator_customisation PUBLIC std::memory_resource)
 endif()
 
 if (CMAKE_SYSTEM_NAME STREQUAL "Linux")

diff --git a/examples/execute.cpp b/examples/execute.cpp
diff --git a/examples/for_each_via_thread_scheduler.cpp b/examples/for_each_via_thread_scheduler.cpp
@@ -19,7 +19,7 @@
 #include <unifex/sync_wait.hpp>
 #include <unifex/then.hpp>
 #include <unifex/transform_stream.hpp>
-#include <unifex/via_stream.hpp>
+#include <unifex/typed_via_stream.hpp>
 
 #include <cstdio>
 
@@ -30,7 +30,7 @@ int main() {
 
   sync_wait(then(
       for_each(
-          via_stream(
+          typed_via_stream(
               context.get_scheduler(),
               transform_stream(
                   range_stream{0, 10},

diff --git a/examples/fp_delegation.cpp b/examples/fp_delegation.cpp
@@ -21,7 +21,7 @@
 #include <unifex/sync_wait.hpp>
 #include <unifex/timed_single_thread_context.hpp>
 #include <unifex/transform_stream.hpp>
-#include <unifex/via_stream.hpp>
+#include <unifex/typed_via_stream.hpp>
 #include <unifex/with_query_value.hpp>
 
 #include <atomic>
@@ -191,10 +191,10 @@ int main() {
   sync_wait(
       then(
           for_each(
-              via_stream(
+              typed_via_stream(
                   outer_delegating_ctx.get_scheduler(),
                   transform_stream(
-                      via_stream(
+                      typed_via_stream(
                           inner_delegating_ctx.get_scheduler(),
                           transform_stream(
                               range_stream{0, 10},

diff --git a/examples/get_scheduler.cpp b/examples/get_scheduler.cpp
@@ -20,7 +20,7 @@
 #include <unifex/sync_wait.hpp>
 #include <unifex/timed_single_thread_context.hpp>
 #include <unifex/transform_stream.hpp>
-#include <unifex/via_stream.hpp>
+#include <unifex/typed_via_stream.hpp>
 #include <unifex/with_query_value.hpp>
 
 #include <chrono>
@@ -45,7 +45,7 @@ int main() {
   // composed operations.
   sync_wait(with_query_value(
       then(
-          for_each(via_stream(current_scheduler,
+          for_each(typed_via_stream(current_scheduler,
                               transform_stream(range_stream{0, 10},
                                                [](int value) {
                                                  return value * value;

diff --git a/examples/submit_allocator_customisation.cpp b/examples/submit_allocator_customisation.cpp
diff --git a/examples/via.cpp b/examples/via.cpp
diff --git a/include/unifex/execute.hpp b/include/unifex/execute.hpp
diff --git a/include/unifex/never.hpp b/include/unifex/never.hpp
@@ -18,7 +18,7 @@
 #include <unifex/config.hpp>
 #include <unifex/get_stop_token.hpp>
 #include <unifex/manual_lifetime.hpp>
-#include <unifex/ready_done_sender.hpp>
+#include <unifex/just_done.hpp>
 #include <unifex/receiver_concepts.hpp>
 #include <unifex/stop_token_concepts.hpp>
 #include <unifex/get_stop_token.hpp>
@@ -101,8 +101,8 @@ struct stream {
   friend constexpr sender tag_invoke(tag_t<next>, stream&) noexcept {
     return {};
   }
-  friend constexpr ready_done_sender tag_invoke(tag_t<cleanup>, stream&) noexcept {
-    return {};
+  friend constexpr auto tag_invoke(tag_t<cleanup>, stream&) noexcept {
+    return just_done();
   }
 };
 } // namespace _never

diff --git a/include/unifex/range_stream.hpp b/include/unifex/range_stream.hpp
@@ -16,7 +16,7 @@
 #pragma once
 
 #include <unifex/blocking.hpp>
-#include <unifex/ready_done_sender.hpp>
+#include <unifex/just_done.hpp>
 #include <unifex/receiver_concepts.hpp>
 #include <unifex/stream_concepts.hpp>
 
@@ -78,8 +78,8 @@ struct stream {
     return next_sender{s};
   }
 
-  friend ready_done_sender tag_invoke(tag_t<cleanup>, stream&) noexcept {
-    return {};
+  friend auto tag_invoke(tag_t<cleanup>, stream&) noexcept {
+    return just_done();
   }
 };