uvco::Udp::RecvAwaiter_ Struct Reference

Collaboration diagram for uvco::Udp::RecvAwaiter_:

Public Types
using	QueueItem_

Public Member Functions
	RecvAwaiter_ ()
bool	await_ready () const
bool	await_suspend (std::coroutine_handle<> handle)
std::optional< std::pair< std::string, AddressHandle > >	await_resume ()

Public Attributes
BoundedQueue< QueueItem_ >	buffer_
std::optional< std::coroutine_handle<> >	handle_
bool	stop_receiving_ = true

Static Public Attributes
static constexpr unsigned	packetQueueSize = 128

Member Typedef Documentation

QueueItem_

using uvco::Udp::RecvAwaiter_::QueueItem_

Initial value:

 
        std::variant<std::pair<std::string, AddressHandle>, uv_status>

Constructor & Destructor Documentation

RecvAwaiter_()

uvco::Udp::RecvAwaiter_::RecvAwaiter_

(

)

: buffer_{packetQueueSize} {}

Member Function Documentation

await_ready()

bool uvco::Udp::RecvAwaiter_::await_ready

(

)

const

{ return !buffer_.empty(); }

await_resume()

std::optional< std::pair< std::string, AddressHandle > > uvco::Udp::RecvAwaiter_::await_resume

(

)

                              {
  // Woken up without read packet: stop receiving.
  if (buffer_.empty()) {
    return std::nullopt;
  }
  QueueItem_ item = buffer_.get();
  if (std::holds_alternative<uv_status>(item)) {
    throw UvcoException(std::get<uv_status>(item),
                        "Udp::RecvAwaiter_::await_resume: error during recv");
  }
  return std::get<std::pair<std::string, AddressHandle>>(item);
}

await_suspend()

bool uvco::Udp::RecvAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

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

Member Data Documentation

buffer_

BoundedQueue<QueueItem_> uvco::Udp::RecvAwaiter_::buffer_

handle_

std::optional<std::coroutine_handle<> > uvco::Udp::RecvAwaiter_::handle_

packetQueueSize

constexpr unsigned uvco::Udp::RecvAwaiter_::packetQueueSize = 128

staticconstexpr

stop_receiving_

bool uvco::Udp::RecvAwaiter_::stop_receiving_ = true

---

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

• uvco/udp.h
• uvco/udp.cc