diff --git a/aether/executors/with_timeout.h b/aether/executors/with_timeout.h index 1b77453e..c1162f86 100644 --- a/aether/executors/with_timeout.h +++ b/aether/executors/with_timeout.h @@ -93,8 +93,8 @@ class Operation { // task_sub controls if task reset or no op_base_.task_sub = ac_.scheduler().DelayedTask( [&]() noexcept { - stdexec::set_error(std::move(op_base_.recv), TimeoutError{}); op_base_.Reset(); + stdexec::set_error(std::move(op_base_.recv), TimeoutError{}); }, duration_);