uvco::StreamBase::ShutdownAwaiter_ Struct Reference

Public Member Functions
	ShutdownAwaiter_ ()=default
bool	await_ready ()
bool	await_suspend (std::coroutine_handle<> handle)
void	await_resume ()

Static Public Member Functions
static void	onShutdown (uv_shutdown_t *req, uv_status status)

Public Attributes
std::optional< std::coroutine_handle<> >	handle_
std::optional< uv_status >	status_

Constructor & Destructor Documentation

ShutdownAwaiter_()

uvco::StreamBase::ShutdownAwaiter_::ShutdownAwaiter_ ( )

default

Member Function Documentation

await_ready()

bool uvco::StreamBase::ShutdownAwaiter_::await_ready

(

)

{ return false; }

await_resume()

void uvco::StreamBase::ShutdownAwaiter_::await_resume

(

)

                                              {
  BOOST_ASSERT(status_);
  if (status_ && *status_ != 0) {
    throw UvcoException{*status_, "StreamBase::shutdown() encountered error"};
  }
}

await_suspend()

bool uvco::StreamBase::ShutdownAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                  {
  BOOST_ASSERT(!handle_);
  handle_ = handle;
  return true;
}

onShutdown()

void uvco::StreamBase::ShutdownAwaiter_::onShutdown ( uv_shutdown_t *  req, uv_status  status  )

static

                                                                {
  auto *awaiter = getRequestData<ShutdownAwaiter_>(req);
  awaiter->status_ = status;
  if (awaiter->handle_) {
    auto handle = awaiter->handle_.value();
    awaiter->handle_.reset();
    Loop::enqueue(handle);
  }
}

Member Data Documentation

handle_

std::optional<std::coroutine_handle<> > uvco::StreamBase::ShutdownAwaiter_::handle_

status_

std::optional<uv_status> uvco::StreamBase::ShutdownAwaiter_::status_

---

The documentation for this struct was generated from the following files:

• uvco/stream.h
• uvco/stream.cc