| 29 | static size_t const dynamic_thread_count = 1; |
| 30 | |
| 31 | void thread(unsigned) |
| 32 | { |
| 33 | exec::single_thread_context ctx; |
| 34 | ex::scheduler auto sch = ctx.get_scheduler(); |
| 35 | |
| 36 | exec::async_scope scope; |
| 37 | std::atomic_bool produced{false}; |
| 38 | ex::sender auto begin = ex::schedule(sch); |
| 39 | { |
| 40 | ex::sender auto ftr = scope.spawn_future(begin | ex::then([&]() { produced.store(true); })); |
| 41 | (void) ftr; |
| 42 | } |
| 43 | ex::sync_wait(scope.on_empty() | ex::then([&]() { RL_ASSERT(produced.load()); })); |
| 44 | } |
| 45 | }; |
| 46 | |
| 47 | struct attach_async_scope_future : rl::test_suite<attach_async_scope_future, 1> |
nothing calls this directly
no test coverage detected