{

explicit schedule_on_transform(SCHEDULER& scheduler) noexcept

: scheduler(scheduler)

{}

SCHEDULER& scheduler;

-> task<detail::remove_rvalue_reference_t<typename awaitable_traits<AWAITABLE>::await_result_t>>

{

co_await scheduler.schedule();

co_return co_await std::move(awaitable);

{

// Transfer exection to the scheduler before the implicit calls to

// 'co_await begin()' or subsequent calls to `co_await iterator::operator++()`

// below. This ensures that all calls to the generator's coroutine_handle<>::resume()

// are executed on the execution context of the scheduler.

co_await scheduler.schedule();

const auto itEnd = source.end();

auto it = co_await source.begin();

while (it != itEnd)

{

co_yield *it;

co_await scheduler.schedule();

(void)co_await ++it;

}