Skip to content

Commit 69c0246

Browse files
committed
fix(stdexec): added adaption to ensure successful build with stdexec
Signed-off-by: David Hua <tkrd1205@gmail.com>
1 parent e9739ca commit 69c0246

2 files changed

Lines changed: 19 additions & 3 deletions

File tree

libs/core/execution_base/include/hpx/execution_base/stdexec_forward.hpp

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,6 @@ namespace hpx::execution::experimental {
162162

163163
// Domain
164164
HPX_CXX_EXPORT using stdexec::default_domain;
165-
HPX_CXX_EXPORT using stdexec::dependent_domain;
166165

167166
// Execute
168167
HPX_CXX_EXPORT using stdexec::execute;
@@ -237,12 +236,10 @@ namespace hpx::execution::experimental {
237236
HPX_CXX_EXPORT using stdexec::sends_stopped;
238237
HPX_CXX_EXPORT using stdexec::value_types_of_t;
239238

240-
HPX_CXX_EXPORT using stdexec::make_completion_signatures;
241239
HPX_CXX_EXPORT using stdexec::transform_completion_signatures;
242240
HPX_CXX_EXPORT using stdexec::transform_completion_signatures_of;
243241

244242
// Transform sender
245-
HPX_CXX_EXPORT using stdexec::transform_env;
246243
HPX_CXX_EXPORT using stdexec::transform_sender;
247244
HPX_CXX_EXPORT using stdexec::transform_sender_result_t;
248245
HPX_CXX_EXPORT using stdexec::transform_sender_t;

libs/core/executors/include/hpx/executors/thread_pool_scheduler.hpp

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -298,6 +298,20 @@ namespace hpx::execution::experimental {
298298
{
299299
return e.sched;
300300
}
301+
302+
// clang-format off
303+
template <typename CPO,
304+
HPX_CONCEPT_REQUIRES_(
305+
meta::value<meta::one_of<
306+
CPO, set_value_t, set_stopped_t>>
307+
)>
308+
// clang-format on
309+
constexpr auto query(
310+
hpx::execution::experimental::get_completion_scheduler_t<
311+
CPO>) const noexcept
312+
{
313+
return sched;
314+
}
301315
};
302316

303317
friend constexpr env tag_invoke(
@@ -355,6 +369,11 @@ namespace hpx::execution::experimental {
355369
return {sched};
356370
}
357371

372+
constexpr sender<thread_pool_policy_scheduler> schedule() const
373+
{
374+
return {*this};
375+
}
376+
358377
void policy(Policy policy) noexcept
359378
{
360379
policy_ = HPX_MOVE(policy);

0 commit comments

Comments
 (0)