diff --git a/include/exec/reschedule.hpp b/include/exec/reschedule.hpp index 8d9f85272..ab8fa5059 100644 --- a/include/exec/reschedule.hpp +++ b/include/exec/reschedule.hpp @@ -58,7 +58,7 @@ namespace exec { friend auto tag_invoke(connect_t, __sender, _Receiver __rcvr) -> connect_result_t<__schedule_sender_t>, _Receiver> { auto __sched = get_scheduler(get_env(__rcvr)); - return connect(schedule(__sched), static_cast<_Receiver&&>(__rcvr)); + return stdexec::connect(schedule(__sched), static_cast<_Receiver&&>(__rcvr)); } friend auto tag_invoke(get_env_t, __sender) noexcept { diff --git a/include/exec/static_thread_pool.hpp b/include/exec/static_thread_pool.hpp index 47429140d..dbd5bd71e 100644 --- a/include/exec/static_thread_pool.hpp +++ b/include/exec/static_thread_pool.hpp @@ -1290,7 +1290,7 @@ namespace exec { __t(static_thread_pool_& pool, Shape shape, Fun fun, CvrefSender&& sndr, Receiver rcvr) : shared_state_(pool, static_cast(rcvr), shape, fun) - , inner_op_{connect(static_cast(sndr), bulk_rcvr{shared_state_})} { + , inner_op_{stdexec::connect(static_cast(sndr), bulk_rcvr{shared_state_})} { } }; @@ -1464,7 +1464,7 @@ namespace exec { while (i0 + chunkSize < size) { for (std::size_t i = i0; i < i0 + chunkSize; ++i) { op.items_[i].__construct_with([&] { - return connect(set_next(op.rcvr_, ItemSender{&op, it + i}), NextReceiver{&op}); + return stdexec::connect(set_next(op.rcvr_, ItemSender{&op, it + i}), NextReceiver{&op}); }); start(op.items_[i].__get()); } @@ -1475,7 +1475,7 @@ namespace exec { } for (std::size_t i = i0; i < size; ++i) { op.items_[i].__construct_with([&] { - return connect(set_next(op.rcvr_, ItemSender{&op, it + i}), NextReceiver{&op}); + return stdexec::connect(set_next(op.rcvr_, ItemSender{&op, it + i}), NextReceiver{&op}); }); start(op.items_[i].__get()); }