unifex::static_thread_pool workers; ex::sender auto accept_and_process_requests() { return ex::on(low_latency.get_scheduler(), accept_request()) | ex::transfer(workers.get_scheduler()) | ex::then([](auto process_request(request_t); extern unifex::static_thread_pool low_latency; extern unifex::static_thread_pool workers; unifex::task accept_and_process_requests() { while (true) { auto request = co_await co_await ex::on(low_latency.get_scheduler(), accept_request()); co_await ex::on(workers.get_scheduler(), process_request(request)); } } Or write it as a coroutine.17 Schedulers produce senders