uvco::StreamBase::OutStreamAwaiter_ Struct Reference

Collaboration diagram for uvco::StreamBase::OutStreamAwaiter_:

Public Member Functions
	OutStreamAwaiter_ (StreamBase &stream, std::span< const char > buffer)
	~OutStreamAwaiter_ ()
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::coroutine_handle	handle_
std::optional< uv_status >	status_
std::span< const char >	buffer_
uv_write_t	write_ {}
StreamBase &	stream_

Constructor & Destructor Documentation

OutStreamAwaiter_()

uvco::StreamBase::OutStreamAwaiter_::OutStreamAwaiter_	(	StreamBase &	stream,
		std::span< const char >	buffer )

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

~OutStreamAwaiter_()

uvco::StreamBase::OutStreamAwaiter_::~OutStreamAwaiter_

(

)

                                                {
  stream_.writer_ = nullptr;
}

Member Function Documentation

await_ready()

bool uvco::StreamBase::OutStreamAwaiter_::await_ready

(

)

                                              {
  // When at this point, we must suspend in any case.
  return false;
}

await_resume()

uv_status uvco::StreamBase::OutStreamAwaiter_::await_resume

(

)

                                                    {
  // resumed due to close.
  if (!stream_.stream_) {
    return UV_ECANCELED;
  }
  BOOST_ASSERT(status_);
  stream_.writer_ = nullptr;
  setData(&write_, (void *)nullptr);
  return *status_;
}

await_suspend()

bool uvco::StreamBase::OutStreamAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                  {
  BOOST_ASSERT(dataIsNull(&write_));
  setData(&write_, this);
  handle_ = handle;
  // For resumption during close.
  stream_.writer_ = handle;
 
  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_);
  Loop::enqueue(awaiter->handle_);
  awaiter->handle_ = nullptr;
  setData(write, (void *)nullptr);
}

prepare_buffers()

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

nodiscard

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

Member Data Documentation

buffer_

std::span<const char> uvco::StreamBase::OutStreamAwaiter_::buffer_

handle_

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

• uvco/stream.cc