uvco::Channel< T >::ChannelAwaiter_ Struct Reference

Collaboration diagram for uvco::Channel< T >::ChannelAwaiter_:

Public Member Functions
	ChannelAwaiter_ (BoundedQueue< T > &queue, BoundedQueue< std::coroutine_handle<> > &slot)
	~ChannelAwaiter_ ()
bool	await_ready ()
bool	await_suspend (std::coroutine_handle<> handle)
bool	await_resume ()

Public Attributes
BoundedQueue< T > &	queue_
BoundedQueue< std::coroutine_handle<> > &	waiters_
std::coroutine_handle	thisCoro_

Constructor & Destructor Documentation

ChannelAwaiter_()

template<typename T>

uvco::Channel< T >::ChannelAwaiter_::ChannelAwaiter_ ( BoundedQueue< T > & queue, BoundedQueue< std::coroutine_handle<> > & slot )

inlineexplicit

        : queue_{queue}, waiters_{slot} {}

~ChannelAwaiter_()

template<typename T>

uvco::Channel< T >::ChannelAwaiter_::~ChannelAwaiter_ ( )

inline

                       {
      // Remove us from waiters.
      waiters_.forEach([this](std::coroutine_handle<> &h) {
        // Remove pending coroutine from waiter queue.
        if (h == thisCoro_) {
          h = nullptr;
        }
      });
    }

Member Function Documentation

await_ready()

template<typename T>

bool uvco::Channel< T >::ChannelAwaiter_::await_ready ( )

inline

{ return false; }

await_resume()

template<typename T>

bool uvco::Channel< T >::ChannelAwaiter_::await_resume ( )

inline

{ return !queue_.empty(); }

await_suspend()

template<typename T>

bool uvco::Channel< T >::ChannelAwaiter_::await_suspend ( std::coroutine_handle<> handle )

inline

                                                     {
      if (!waiters_.hasSpace()) {
        throw UvcoException(
            UV_EBUSY,
            "too many coroutines waiting for reading/writing a channel");
      }
      thisCoro_ = handle;
      waiters_.put(handle);
      return true;
    }

Member Data Documentation

queue_

template<typename T>

BoundedQueue<T>& uvco::Channel< T >::ChannelAwaiter_::queue_

thisCoro_

template<typename T>

std::coroutine_handle uvco::Channel< T >::ChannelAwaiter_::thisCoro_

waiters_

template<typename T>

BoundedQueue<std::coroutine_handle<> >& uvco::Channel< T >::ChannelAwaiter_::waiters_

---

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

• uvco/channel.h