uvco::TimerAwaiter Class Reference

Public Member Functions
	TimerAwaiter (const Loop &loop, uint64_t millis, bool repeating=false)
	TimerAwaiter (const TimerAwaiter &)=delete
	TimerAwaiter (TimerAwaiter &&other)=delete
TimerAwaiter &	operator= (const TimerAwaiter &)=delete
TimerAwaiter &	operator= (TimerAwaiter &&other)=delete
	~TimerAwaiter ()
void	close ()
bool	await_ready ()
std::coroutine_handle	await_suspend (std::coroutine_handle<> handle)
bool	await_resume ()
bool	isReady ()
void	stop ()
void	resume ()

Private Attributes
std::unique_ptr< uv_timer_t >	timer_
std::coroutine_handle	handle_
bool	closed_ = false
bool	stopped_ = false

Constructor & Destructor Documentation

TimerAwaiter() [1/3]

uvco::TimerAwaiter::TimerAwaiter ( const Loop & loop, uint64_t millis, bool repeating = false )

inline

      : timer_{std::make_unique<uv_timer_t>()} {
    uv_timer_init(loop.uvloop(), timer_.get());
    setData(timer_.get(), this);
    if (repeating) {
      uv_timer_start(timer_.get(), onMultiTimerFired, millis, millis);
    } else {
      uv_timer_start(timer_.get(), onSingleTimerDone, millis, 0);
    }
  }

TimerAwaiter() [2/3]

uvco::TimerAwaiter::TimerAwaiter ( const TimerAwaiter & )

delete

TimerAwaiter() [3/3]

uvco::TimerAwaiter::TimerAwaiter ( TimerAwaiter && other )

delete

~TimerAwaiter()

uvco::TimerAwaiter::~TimerAwaiter ( )

inline

                  {
    stop();
    close();
  }

Member Function Documentation

await_ready()

bool uvco::TimerAwaiter::await_ready ( )

inline

{ return isReady(); }

await_resume()

bool uvco::TimerAwaiter::await_resume ( )

inlinenodiscard

                                    {
    handle_ = nullptr;
    return !stopped_;
  }

await_suspend()

std::coroutine_handle uvco::TimerAwaiter::await_suspend ( std::coroutine_handle<> handle )

inline

                                                                    {
    handle_ = handle;
    return Loop::getNext();
  }

close()

void uvco::TimerAwaiter::close ( )

inline

               {
    if (!timer_ || closed_) {
      return;
    }
    closed_ = true;
    // If the timer is already closing, we don't need to close it again.
    // This would cause an error in libuv.
    if (timer_ != nullptr && isClosed(timer_.get())) {
      return;
    }
    stop();
    closeHandle(timer_.release());
  }

isReady()

bool uvco::TimerAwaiter::isReady ( )

inline

                 {
    uint64_t due = uv_timer_get_due_in(timer_.get());
    return due == 0;
  }

operator=() [1/2]

TimerAwaiter & uvco::TimerAwaiter::operator= ( const TimerAwaiter & )

delete

operator=() [2/2]

TimerAwaiter & uvco::TimerAwaiter::operator= ( TimerAwaiter && other )

delete

resume()

void uvco::TimerAwaiter::resume ( )

inline

                {
    if (handle_) {
      Loop::enqueue(handle_);
      handle_ = nullptr;
    }
  }

stop()

void uvco::TimerAwaiter::stop ( )

inline

              {
    if (!stopped_) {
      uv_timer_stop(timer_.get());
      stopped_ = true;
    }
  }

Member Data Documentation

closed_

bool uvco::TimerAwaiter::closed_ = false

private

handle_

std::coroutine_handle uvco::TimerAwaiter::handle_

private

stopped_

bool uvco::TimerAwaiter::stopped_ = false

private

timer_

std::unique_ptr<uv_timer_t> uvco::TimerAwaiter::timer_

private

---

The documentation for this class was generated from the following file:

• uvco/timer.cc