Delay.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <chrono>
#include <coroutine>
#include <thread>
 
namespace corium::async {
 
struct YieldAwaiter {
    [[nodiscard]] constexpr bool await_ready() const noexcept { return false; }
    void await_suspend(std::coroutine_handle<> handle) const noexcept {
        handle.resume();
    }
    constexpr void await_resume() const noexcept {}
};
 
[[nodiscard]] inline constexpr YieldAwaiter yield() noexcept {
    return YieldAwaiter{};
}
 
template <typename Rep, typename Period>
struct DelayAwaiter {
    std::chrono::duration<Rep, Period> duration;
 
    [[nodiscard]] constexpr bool await_ready() const noexcept {
        return duration.count() <= 0;
    }
 
    void await_suspend(std::coroutine_handle<> handle) const {
        std::this_thread::sleep_for(duration);
        handle.resume();
    }
 
    constexpr void await_resume() const noexcept {}
};
 
template <typename Rep, typename Period>
[[nodiscard]] inline auto delay(const std::chrono::duration<Rep, Period>& d) noexcept {
    return DelayAwaiter<Rep, Period>{d};
}
 
} // namespace corium::async