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::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_.value() != 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

                                                                {
  const std::unique_ptr<uv_shutdown_t> uniqueReq{req};
  auto *awaiter = getRequestDataOrNull<ShutdownAwaiter_>(uniqueReq.get());
  if (awaiter == nullptr) {
    // shutdown coroutine was ancelled.
    return;
  }
  awaiter->status_ = status;
  if (awaiter->handle_) {
    Loop::enqueue(awaiter->handle_);
    awaiter->handle_ = nullptr;
  }
}

Member Data Documentation

handle_

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 file:

• uvco/stream.cc