spawn clears the cancellation_slot.

boostorg · Sep 19, 2024 · 7f8c3f4 · 7f8c3f4
1 parent d68d7d4
commit 7f8c3f4
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/include/boost/cobalt/detail/spawn.hpp b/include/boost/cobalt/detail/spawn.hpp
@@ -74,9 +74,12 @@ struct async_initiate_spawn
 
       decltype(recs) r;
       Handler handler;
+      asio::cancellation_slot sl;
 
       void operator()()
       {
+        if (sl.is_connected())
+          sl.clear();
         auto ex = r->exception;
         T rr{};
         if (r->result)
@@ -88,7 +91,7 @@ struct async_initiate_spawn
 
     p->awaited_from.reset(detail::post_coroutine(
         completion_handler{
-            alloc, asio::get_associated_executor(h, exec), std::move(recs), std::move(h)
+            alloc, asio::get_associated_executor(h, exec), std::move(recs), std::move(h), sl
         }).address());
 
     asio::dispatch(exec, std::coroutine_handle<detail::task_promise<T>>::from_promise(*p->promise));