Skip to content

Commit 1e2e255

Browse files
authored
fixed get_completion_scheduler for inline_scheduler (#295)
* fixed get_completion_scheduler for inline_scheduler * add missing import
1 parent cf4b2a7 commit 1e2e255

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

include/beman/execution/detail/inline_scheduler.hpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import std;
1313
#include <utility>
1414
#endif
1515
#ifdef BEMAN_HAS_MODULES
16+
import beman.execution.detail.get_scheduler;
1617
import beman.execution.detail.sender;
1718
import beman.execution.detail.receiver;
1819
import beman.execution.detail.set_value;
@@ -59,6 +60,8 @@ struct inline_scheduler {
5960
-> state<Rcvr> {
6061
return {::std::forward<Rcvr>(receiver)};
6162
}
63+
64+
inline_scheduler query(const ::beman::execution::get_scheduler_t&) const noexcept { return {}; }
6265
};
6366

6467
static constexpr auto schedule() noexcept -> sender { return {}; }

tests/beman/execution/exec-inline-scheduler.test.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,9 @@ auto test_sender_env_is_inline_attrs() {
148148
auto sndr = test_std::schedule(test_std::inline_scheduler{});
149149
auto attrs = test_std::get_env(sndr);
150150
static_assert(std::same_as<decltype(attrs), test_detail::inline_attrs<test_std::set_value_t>>);
151+
152+
auto sched = test_std::get_completion_scheduler<test_std::set_value_t>(test_std::get_env(sndr), sndr);
153+
static_assert(std::same_as<decltype(sched), test_std::inline_scheduler>);
151154
}
152155

153156
auto test_inline_attrs_completion_scheduler() {

0 commit comments

Comments
 (0)