uvco::StreamBase::OutStreamAwaiter_ Struct Reference

Collaboration diagram for uvco::StreamBase::OutStreamAwaiter_:

Public Member Functions
	OutStreamAwaiter_ (StreamBase &stream, std::string_view buffer)
std::array< uv_buf_t, 1 >	prepare_buffers () const
bool	await_ready ()
bool	await_suspend (std::coroutine_handle<> handle)
uv_status	await_resume ()

Static Public Member Functions
static void	onOutStreamWrite (uv_write_t *write, uv_status status)

Public Attributes
std::optional< std::coroutine_handle<> >	handle_
std::optional< uv_status >	status_
std::string_view	buffer_
uv_write_t	write_ {}
StreamBase &	stream_

Constructor & Destructor Documentation

OutStreamAwaiter_()

uvco::StreamBase::OutStreamAwaiter_::OutStreamAwaiter_	(	StreamBase &	stream,
		std::string_view	buffer
	)

    : buffer_{buffer}, write_{}, stream_{stream} {}

Member Function Documentation

await_ready()

bool uvco::StreamBase::OutStreamAwaiter_::await_ready

(

)

                                              {
  // Attempt early write:
  auto bufs = prepare_buffers();
  uv_status result = uv_try_write(&stream_.stream(), bufs.data(), bufs.size());
  if (result > 0) {
    status_ = result;
  }
  return result > 0;
}

await_resume()

uv_status uvco::StreamBase::OutStreamAwaiter_::await_resume

(

)

                                                    {
  // resumed due to close.
  if (!stream_.stream_) {
    return UV_ECANCELED;
  }
  BOOST_ASSERT(status_);
  stream_.writer_.reset();
  return *status_;
}

await_suspend()

bool uvco::StreamBase::OutStreamAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                  {
  BOOST_ASSERT(write_.data == nullptr);
  write_.data = this;
  handle_ = handle;
  // For resumption during close.
  stream_.writer_ = handle;
  auto bufs = prepare_buffers();
  // TODO: move before suspension point.
  uv_write(&write_, &stream_.stream(), bufs.data(), bufs.size(),
           onOutStreamWrite);
 
  return true;
}

onOutStreamWrite()

void uvco::StreamBase::OutStreamAwaiter_::onOutStreamWrite ( uv_write_t *  write, uv_status  status  )

static

                                                                       {
  auto *awaiter = getRequestData<OutStreamAwaiter_>(write);
  BOOST_ASSERT(awaiter != nullptr);
  awaiter->status_ = status;
  BOOST_ASSERT(awaiter->handle_);
  auto handle = awaiter->handle_.value();
  awaiter->handle_.reset();
  Loop::enqueue(handle);
  setData(write, (void*) nullptr);
}

prepare_buffers()

std::array< uv_buf_t, 1 > uvco::StreamBase::OutStreamAwaiter_::prepare_buffers

(

)

const

                                                                         {
  std::array<uv_buf_t, 1> bufs{};
  bufs[0].base = const_cast<char *>(buffer_.data());
  bufs[0].len = buffer_.size();
  return bufs;
}

Member Data Documentation

buffer_

std::string_view uvco::StreamBase::OutStreamAwaiter_::buffer_

handle_

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

status_

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

stream_

StreamBase& uvco::StreamBase::OutStreamAwaiter_::stream_

write_

uv_write_t uvco::StreamBase::OutStreamAwaiter_::write_ {}

{};

---

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

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