exec_coro.hpp

Go to the documentation of this file.

#pragma once
 
#include "records.hpp"
 
#include <chrono>
#include <coroutine>
#include <exception>
#include <optional>
 
namespace joque
{
 
class exec_coro
{
public:
        struct promise_type;
 
        exec_coro( std::coroutine_handle< promise_type > h );
 
        exec_coro( exec_coro&& other ) noexcept;
        exec_coro& operator=( exec_coro&& other ) noexcept;
 
        [[nodiscard]] bool done() const;
 
        [[nodiscard]] std::optional< exec_record > result();
 
        void tick();
 
        std::optional< exec_record >
        run( std::chrono::milliseconds period = std::chrono::milliseconds{ 5 } );
 
        ~exec_coro();
 
private:
        std::coroutine_handle< promise_type > h_;
};
 
struct exec_coro::promise_type
{
        [[nodiscard]] exec_coro get_return_object();
 
        [[nodiscard]] std::suspend_always initial_suspend() const;
 
        [[nodiscard]] std::suspend_always final_suspend() const noexcept;
 
        void unhandled_exception();
 
        void return_value( exec_record rec );
 
        std::optional< exec_record > value;
 
        std::exception_ptr excep;
};
 
}  // namespace joque