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)
bool	await_ready ()
bool	await_suspend (std::coroutine_handle<> handle)
bool	await_resume ()

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

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} {}

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");
      }
      waiters_.put(handle);
      return true;
    }

Member Data Documentation

queue_

template<typename T >

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

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