uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_ Struct Reference

Public Types
using	Accepted = std::variant<uv_status, StreamType>

Public Member Functions
	ConnectionAwaiter_ (UvStreamType &socket)
	~ConnectionAwaiter_ ()
bool	await_ready () const
bool	await_suspend (std::coroutine_handle<> handle)
bool	await_resume () const
void	stop ()
	Stop a listener coroutine.

Public Attributes
UvStreamType &	socket_
std::coroutine_handle	handle_
std::vector< Accepted >	accepted_
bool	stopped_ = false

Member Typedef Documentation

Accepted

template<typename UvStreamType, typename StreamType>

using uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::Accepted = std::variant<uv_status, StreamType>

Constructor & Destructor Documentation

ConnectionAwaiter_()

template<typename UvStreamType, typename StreamType>

uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::ConnectionAwaiter_ ( UvStreamType & socket )

inlineexplicit

                                                    : socket_{socket} {
    accepted_.reserve(4);
    setData(&socket_, this);
  }

~ConnectionAwaiter_()

template<typename UvStreamType, typename StreamType>

uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::~ConnectionAwaiter_ ( )

inline

{ resetData(&socket_); }

Member Function Documentation

await_ready()

template<typename UvStreamType, typename StreamType>

bool uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::await_ready ( ) const

nodiscard

                                                                       {
  return !accepted_.empty();
}

await_resume()

template<typename UvStreamType, typename StreamType>

bool uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::await_resume ( ) const

inlinenodiscard

{ return !stopped_; }

await_suspend()

template<typename UvStreamType, typename StreamType>

bool uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

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

stop()

template<typename UvStreamType, typename StreamType>

void uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::stop

(

)

Stop a listener coroutine.

                                                                        {
  if (stopped_) {
    return;
  }
  stopped_ = true;
  if (handle_ != nullptr) {
    // Synchronous resume to ensure that the listener is stopped by the time
    // the function returns.
    const std::coroutine_handle<> handle = handle_;
    handle_ = nullptr;
    handle.resume();
  }
}

Member Data Documentation

accepted_

template<typename UvStreamType, typename StreamType>

std::vector<Accepted> uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::accepted_

handle_

template<typename UvStreamType, typename StreamType>

std::coroutine_handle uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::handle_

socket_

template<typename UvStreamType, typename StreamType>

UvStreamType& uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::socket_

stopped_

template<typename UvStreamType, typename StreamType>

bool uvco::StreamServerBase< UvStreamType, StreamType >::ConnectionAwaiter_::stopped_ = false

---

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

• uvco/stream_server_base_impl.cc