From 567bc83422d3521eacc24dfc3efb9f6e95434b31 Mon Sep 17 00:00:00 2001
From: Minh Vu <vuhoangminh97@gmail.com>
Date: Sat, 15 Aug 2026 13:12:28 +0200
Subject: [PATCH 1/2] Fix nvexec launch callable forwarding

---
 include/nvexec/stream/launch.cuh |  5 ++++-
 test/nvexec/launch.cpp           | 27 +++++++++++++++++++++++++++
 2 files changed, 31 insertions(+), 1 deletion(-)

diff --git a/include/nvexec/stream/launch.cuh b/include/nvexec/stream/launch.cuh
index 187da083b..c2ccec7f9 100644
--- a/include/nvexec/stream/launch.cuh
+++ b/include/nvexec/stream/launch.cuh
@@ -141,7 +141,10 @@ namespace nv::execution
           static_cast<Self&&>(self).sndr_,
           static_cast<Receiver&&>(rcvr),
           [&](_strm::opstate_base<Receiver>& stream_provider) -> receiver_t<Receiver>
-          { return receiver_t<Receiver>(stream_provider, self.fun_, self.params_); });
+          {
+            return receiver_t<Receiver>(
+              stream_provider, static_cast<Self&&>(self).fun_, self.params_);
+          });
       }
       STDEXEC_EXPLICIT_THIS_END(connect)
 
diff --git a/test/nvexec/launch.cpp b/test/nvexec/launch.cpp
index 7a9d69a98..687f147fa 100644
--- a/test/nvexec/launch.cpp
+++ b/test/nvexec/launch.cpp
@@ -18,6 +18,8 @@
 #include <test_common/catch2.hpp>
 #include <test_common/type_helpers.hpp>
 
+#include <type_traits>
+
 #include "common.cuh"
 #include "nvexec/stream_context.cuh"
 
@@ -50,6 +52,31 @@ namespace
       return std::accumulate(input.begin(), input.end(), 0);
     }
 
+    struct move_only_launch_handler
+    {
+      move_only_launch_handler()                                  = default;
+      move_only_launch_handler(move_only_launch_handler const &) = delete;
+
+      STDEXEC_ATTRIBUTE(host, device)
+      move_only_launch_handler(move_only_launch_handler &&) = default;
+
+      STDEXEC_ATTRIBUTE(host, device) void operator()(cudaStream_t) const {}
+    };
+
+    static_assert(std::is_trivially_copyable_v<move_only_launch_handler>);
+    static_assert(!std::is_copy_constructible_v<move_only_launch_handler>);
+
+    TEST_CASE("nvexec launch supports move-only function objects",
+              "[cuda][stream][adaptors][launch]")
+    {
+      nvexec::stream_context stream_ctx{};
+
+      auto snd = STDEXEC::just() | STDEXEC::continues_on(stream_ctx.get_scheduler())
+               | nvexec::launch(move_only_launch_handler{});
+
+      REQUIRE(STDEXEC::sync_wait(std::move(snd)).has_value());
+    }
+
     TEST_CASE("nvexec launch advertises CUDA launch errors", "[cuda][stream][adaptors][launch]")
     {
       nvexec::stream_context stream{};

From 6d120015b0d79da99318dd74b1709d99de1c477d Mon Sep 17 00:00:00 2001
From: Minh Vu <vuhoangminh97@gmail.com>
Date: Sat, 15 Aug 2026 20:03:52 +0200
Subject: [PATCH 2/2] clang-format nvexec launch changes

---
 include/nvexec/stream/launch.cuh | 5 +++--
 test/nvexec/launch.cpp           | 4 ++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/include/nvexec/stream/launch.cuh b/include/nvexec/stream/launch.cuh
index c2ccec7f9..37b1a1881 100644
--- a/include/nvexec/stream/launch.cuh
+++ b/include/nvexec/stream/launch.cuh
@@ -142,8 +142,9 @@ namespace nv::execution
           static_cast<Receiver&&>(rcvr),
           [&](_strm::opstate_base<Receiver>& stream_provider) -> receiver_t<Receiver>
           {
-            return receiver_t<Receiver>(
-              stream_provider, static_cast<Self&&>(self).fun_, self.params_);
+            return receiver_t<Receiver>(stream_provider,
+                                        static_cast<Self&&>(self).fun_,
+                                        self.params_);
           });
       }
       STDEXEC_EXPLICIT_THIS_END(connect)
diff --git a/test/nvexec/launch.cpp b/test/nvexec/launch.cpp
index 687f147fa..54cbec6c5 100644
--- a/test/nvexec/launch.cpp
+++ b/test/nvexec/launch.cpp
@@ -54,11 +54,11 @@ namespace
 
     struct move_only_launch_handler
     {
-      move_only_launch_handler()                                  = default;
+      move_only_launch_handler()                                 = default;
       move_only_launch_handler(move_only_launch_handler const &) = delete;
 
       STDEXEC_ATTRIBUTE(host, device)
-      move_only_launch_handler(move_only_launch_handler &&) = default;
+      move_only_launch_handler(move_only_launch_handler&&) = default;
 
       STDEXEC_ATTRIBUTE(host, device) void operator()(cudaStream_t) const {}
     };