Method thread

test/rrd/async_scope.cpp:51–62

  static size_t const dynamic_thread_count = 1;

  void thread(unsigned)
  {
    exec::single_thread_context ctx;
    ex::scheduler auto          sch = ctx.get_scheduler();

    exec::async_scope scope;
    std::atomic_bool  produced{false};
    ex::sender auto   begin = ex::schedule(sch);
    ex::sender auto   ftr   = scope.spawn_future(begin | ex::then([&]() { produced.store(true); }));
    ex::sender auto   ftr_then = std::move(ftr) | ex::then([&] { RL_ASSERT(produced.load()); });
    ex::sync_wait(ex::when_all(scope.on_empty(), std::move(ftr_then)));
  }
};

struct async_scope_future_set_result : rl::test_suite<async_scope_future_set_result, 1>