uvco::StreamBase::OutStreamAwaiter_ Struct Reference

Collaboration diagram for uvco::StreamBase::OutStreamAwaiter_:

Classes
struct	UvWriteWithBuffer

Public Member Functions
	OutStreamAwaiter_ (StreamBase &stream, std::string buffer)
	~OutStreamAwaiter_ ()
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_
std::unique_ptr< UvWriteWithBuffer >	write_
StreamBase &	stream_

Constructor & Destructor Documentation

OutStreamAwaiter_()

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

    : buffer_{buffer}, write_{std::make_unique<UvWriteWithBuffer>()},
      stream_{stream} {
  write_->buffer = std::move(buffer);
}

~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;
  return *status_;
}

await_suspend()

bool uvco::StreamBase::OutStreamAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                  {
  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

                                                                       {
  const std::unique_ptr<UvWriteWithBuffer> req{(UvWriteWithBuffer *)write};
  auto *awaiter = getRequestDataOrNull<OutStreamAwaiter_>(req.get());
  if (awaiter == nullptr) {
    return;
  }
  BOOST_ASSERT(awaiter != nullptr);
  awaiter->status_ = status;
  BOOST_ASSERT(awaiter->handle_);
  Loop::enqueue(awaiter->handle_);
  awaiter->handle_ = nullptr;
  setData(write, (void *)nullptr);
}

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_

std::unique_ptr<UvWriteWithBuffer> uvco::StreamBase::OutStreamAwaiter_::write_

---

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

• uvco/stream.cc