Home
last modified time | relevance | path

Searched refs:stdexec (Results 1 – 25 of 108) sorted by relevance

12345

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__p2300.hpp
H A D__cpo.hpp
H A D__run_loop.hpp
H A D__receiver_ref.hpp
H A D__schedule_from.hpp
H A D__continues_on.hpp
H A D__read_env.hpp
H A D__connect_awaitable.hpp
H A D__basic_sender.hpp
H A D__spin_loop_pause.hpp
H A D__stopped_as_optional.hpp
H A D__config.hpp
H A D__awaitable.hpp
H A D__let.hpp
H A D__on.hpp
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp
H A Denv.hpp
H A Dasync_scope.hpp
H A Dany_sender_of.hpp
H A Dexecution.hpp
H A Dat_coroutine_exit.hpp
/openbmc/sdbusplus/test/async/
H A Dtask.cpp20 stdexec::sync_wait(t()); in TEST()
44 stdexec::sync_wait(_::two(executed)); in TEST()
72 EXPECT_THROW(stdexec::sync_wait(_::one()), std::logic_error); in TEST()
76 stdexec::sync_wait(_::two(caught)); in TEST()
91 co_return co_await stdexec::just(0); in TEST()
98 stdexec::sync_wait( in TEST()
100 stdexec::then([=](auto result) { EXPECT_EQ(result, count); })); in TEST()
H A Dcontext.cpp18 ctx->spawn(stdexec::just() | in spawnStop()
19 stdexec::then([this]() { ctx->request_stop(); })); in spawnStop()
38 ctx->spawn(stdexec::just()); in TEST_F()
60 stdexec::then([&ran]() { ran = true; })); in TEST_F()
83 co_return co_await stdexec::just(0); in TEST_F()
91 stdexec::then([=](auto result) { EXPECT_EQ(result, count); })); in TEST_F()
108 ctx->spawn(m->next() | stdexec::then([&ran](...) { ran = true; })); in TEST_F()
112 stdexec::then([&m](...) { m.reset(); })); in TEST_F()
140 stdexec::then([&]() { m.reset(); })); in TEST_F()
/openbmc/pldm/requester/
H A Dhandler.hpp409 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto sendRecvMsg(
468 template <class RequestInterface, stdexec::receiver R>
499 friend void tag_invoke(stdexec::start_t, SendRecvMsgOperation& op) noexcept in tag_invoke()
501 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
506 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
516 return stdexec::set_value(std::move(op.receiver), rc, in tag_invoke()
536 return stdexec::set_stopped(std::move(receiver)); in onStop()
557 return stdexec::set_value(std::move(receiver), static_cast<int>(rc), in onComplete()
591 std::optional<typename stdexec::stop_token_of_t<
592 stdexec::env_of_t<R>>::template callback_type<std::function<void()>>>
[all …]
/openbmc/pldm/requester/test/
H A Dhandler_test.cpp175 stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
200 exec::default_task_context<void>(stdexec::inline_scheduler{})); in TEST_F()
208 stdexec::sync_wait(scope.on_empty()); in TEST_F()
223 stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
233 }) | stdexec::upon_stopped([&] { stopped = true; }), in TEST_F()
234 exec::default_task_context<void>(stdexec::inline_scheduler{})); in TEST_F()
240 stdexec::sync_wait(scope.on_empty()); in TEST_F()
280 scope.spawn(stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
288 exec::default_task_context<void>(stdexec::inline_scheduler{})); in TEST_F()
303 stdexec::sync_wait(scope.on_empty()); in TEST_F()

12345