basic_waitable_timer.hpp

Go to the documentation of this file.

#ifndef KAGOME_BASIC_WAITABLE_TIMER_HPP
#define KAGOME_BASIC_WAITABLE_TIMER_HPP

#include <boost/asio/basic_waitable_timer.hpp>
#include <boost/asio/io_context.hpp>
#include "clock/timer.hpp"

namespace kagome::clock {
  class BasicWaitableTimer : public Timer {
   public:
    explicit BasicWaitableTimer(
        std::shared_ptr<boost::asio::io_context> io_context);

    ~BasicWaitableTimer() override = default;

    void expiresAt(clock::SystemClock::TimePoint at) override;

    void expiresAfter(clock::SystemClock::Duration duration) override;

    void cancel() override;

    void asyncWait(
        const std::function<void(const std::error_code &)> &h) override;

   private:
    std::shared_ptr<boost::asio::io_context> io_context_;
    boost::asio::basic_waitable_timer<std::chrono::system_clock> timer_;
  };
}  // namespace kagome::clock

#endif  // KAGOME_BASIC_WAITABLE_TIMER_HPP