uvco::TcpClient::ConnectAwaiter_ Struct Reference

Public Member Functions
	ConnectAwaiter_ ()
	~ConnectAwaiter_ ()
bool	await_ready () const
bool	await_suspend (std::coroutine_handle<> handle)
TcpStream	await_resume ()
void	onConnect (uv_status status)

Public Attributes
std::unique_ptr< uv_connect_t >	req_
std::unique_ptr< uv_tcp_t >	socket_
std::coroutine_handle	handle_
std::optional< uv_status >	status_

Constructor & Destructor Documentation

ConnectAwaiter_()

uvco::TcpClient::ConnectAwaiter_::ConnectAwaiter_

(

)

    : req_{std::make_unique<uv_connect_t>()},
      socket_{std::make_unique<uv_tcp_t>()} {
  setRequestData(req_.get(), this);
}

~ConnectAwaiter_()

uvco::TcpClient::ConnectAwaiter_::~ConnectAwaiter_

(

)

                                           {
  if (!requestDataIsNull(req_.get())) {
    resetRequestData(req_.get());
    uv_cancel((uv_req_t *)req_.release());
  }
  if (socket_ != nullptr) {
    closeHandle(socket_.release(), uvCloseReset);
  }
}

Member Function Documentation

await_ready()

bool uvco::TcpClient::ConnectAwaiter_::await_ready ( ) const

nodiscard

                                                 {
  return status_.has_value();
}

await_resume()

TcpStream uvco::TcpClient::ConnectAwaiter_::await_resume

(

)

                                                 {
  resetRequestData(req_.get());
  BOOST_ASSERT(status_);
  if (status_.value() != 0) {
    throw UvcoException{status_.value(),
                        "TcpClient::connect() connection failed"};
  }
  return TcpStream{std::move(socket_)};
}

await_suspend()

bool uvco::TcpClient::ConnectAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

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

onConnect()

void uvco::TcpClient::ConnectAwaiter_::onConnect

(

uv_status

status

)

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

Member Data Documentation

handle_

std::coroutine_handle uvco::TcpClient::ConnectAwaiter_::handle_

req_

std::unique_ptr<uv_connect_t> uvco::TcpClient::ConnectAwaiter_::req_

socket_

std::unique_ptr<uv_tcp_t> uvco::TcpClient::ConnectAwaiter_::socket_

status_

std::optional<uv_status> uvco::TcpClient::ConnectAwaiter_::status_

---

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

• uvco/tcp.cc