#ifndef CPPCORO_SCHEDULE_ON_HPP_INCLUDED

#define CPPCORO_SCHEDULE_ON_HPP_INCLUDED

#include <cppcoro/task.hpp>

#include <cppcoro/shared_task.hpp>

#include <cppcoro/async_generator.hpp>

namespace cppcoro

{

template<typename SCHEDULER>

struct schedule_on_transform

};

template<typename SCHEDULER>

schedule_on_transform<SCHEDULER> schedule_on(SCHEDULER& scheduler)

{

return schedule_on_transform<SCHEDULER>{ scheduler };

}

template<typename T, typename SCHEDULER>

decltype(auto) operator|(T&& value, schedule_on_transform<SCHEDULER> transform)

{

return schedule_on(transform.scheduler, std::forward<T>(value));

}

template<typename T, typename SCHEDULER>

task<T> schedule_on(SCHEDULER& scheduler, task<T> task)

}

template<typename T, typename SCHEDULER>

async_generator<T> schedule_on(SCHEDULER& scheduler, async_generator<T> source)

}

}

#endif