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

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

Public Member Functions
	ConnectionAwaiter_ (UvStreamType &socket)
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::optional< 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);
    }

Member Function Documentation

await_ready()

template<typename UvStreamType , typename StreamType >

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

(

)

const

                                                                       {
  return !accepted_.empty();
}

await_resume()

template<typename UvStreamType , typename StreamType >

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

inline

{ return !stopped_; }

await_suspend()

template<typename UvStreamType , typename StreamType >

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

(

std::coroutine_handle<>

handle

)

                                                {
  BOOST_ASSERT(!handle_);
  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_) {
    // Synchronous resume to ensure that the listener is stopped by the time
    // the function returns.
    const auto handle = *handle_;
    handle_.reset();
    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::optional<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 files:

• uvco/stream_server_base.h
• uvco/stream_server_base_impl.cc