folly::pushmi::any_receiver< E, VN > Class Template Reference

#include <forwards.h>

Classes
union	data
struct	vtable

Public Types
using	properties = property_set< is_receiver<>>

Public Member Functions
	any_receiver ()=default
	any_receiver (any_receiver &&that) noexcept
requires ReceiveValue< wrapped_t< Wrapped >, VN... > &&ReceiveError< Wrapped, E >	any_receiver (Wrapped obj) noexcept(insitu< Wrapped >())
	~any_receiver ()
any_receiver &	operator= (any_receiver &&that) noexcept
void	value (VN &&...vn)
void	error (E e) noexcept
void	done ()

Private Types
template<class T , class U = std::decay_t<T>>
using	wrapped_t = std::enable_if_t<!std::is_same< U, any_receiver >::value, U >

Private Member Functions
template<class Wrapped >
	any_receiver (Wrapped obj, std::false_type)
template<class Wrapped >
	any_receiver (Wrapped obj, std::true_type) noexcept

Static Private Member Functions
template<class Wrapped >
static constexpr bool	insitu () noexcept
template<class Wrapped >
static void	check ()

Private Attributes
bool	done_ = false
union folly::pushmi::any_receiver::data	data_
vtable const *	vptr_ = &noop_

Static Private Attributes
static constexpr vtable const	noop_ {}

Detailed Description

template<class E, class... VN>
class folly::pushmi::any_receiver< E, VN >

Definition at line 101 of file forwards.h.

Member Typedef Documentation

template<class E, class... VN>

using folly::pushmi::any_receiver< E, VN >::properties = property_set<is_receiver<>>

Definition at line 118 of file receiver.h.

template<class E, class... VN>

template<class T , class U = std::decay_t<T>>

using folly::pushmi::any_receiver< E, VN >::wrapped_t = std::enable_if_t<!std::is_same<U, any_receiver>::value, U>

private

Definition at line 58 of file receiver.h.

Constructor & Destructor Documentation

template<class E, class... VN>

template<class Wrapped >

folly::pushmi::any_receiver< E, VN >::any_receiver ( Wrapped  obj, std::false_type    )

inlineprivate

Definition at line 72 of file receiver.h.

                                           : any_receiver() {
    struct s {
      static void op(data& src, data* dst) {
        if (dst)
          dst->pobj_ = std::exchange(src.pobj_, nullptr);
        delete static_cast<Wrapped const*>(src.pobj_);
      }
      static void done(data& src) {
        set_done(*static_cast<Wrapped*>(src.pobj_));
      }
      static void error(data& src, E e) noexcept {
        set_error(*static_cast<Wrapped*>(src.pobj_), std::move(e));
      }
      static void value(data& src, VN... vn) {
        set_value(*static_cast<Wrapped*>(src.pobj_), std::move(vn)...);
      }
    };
    static const vtable vtbl{s::op, s::done, s::error, s::value};
    data_.pobj_ = new Wrapped(std::move(obj));
    vptr_ = &vtbl;
  }

template<class E, class... VN>

template<class Wrapped >

folly::pushmi::any_receiver< E, VN >::any_receiver ( Wrapped  obj, std::true_type    )

inlineprivatenoexcept

Definition at line 94 of file receiver.h.

                                                   : any_receiver() {
    struct s {
      static void op(data& src, data* dst) {
        if (dst)
          new (dst->buffer_)
              Wrapped(std::move(*static_cast<Wrapped*>((void*)src.buffer_)));
        static_cast<Wrapped const*>((void*)src.buffer_)->~Wrapped();
      }
      static void done(data& src) {
        set_done(*static_cast<Wrapped*>((void*)src.buffer_));
      }
      static void error(data& src, E e) noexcept {
        set_error(*static_cast<Wrapped*>((void*)src.buffer_), std::move(e));
      }
      static void value(data& src, VN... vn) {
        set_value(*static_cast<Wrapped*>((void*)src.buffer_), std::move(vn)...);
      }
    };
    static const vtable vtbl{s::op, s::done, s::error, s::value};
    new ((void*)data_.buffer_) Wrapped(std::move(obj));
    vptr_ = &vtbl;
  }

template<class E, class... VN>

folly::pushmi::any_receiver< E, VN >::any_receiver ( )

default

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::operator=().

template<class E, class... VN>

folly::pushmi::any_receiver< E, VN >::any_receiver ( any_receiver< E, VN > &&  that )

inlinenoexcept

Definition at line 121 of file receiver.h.

                                             : any_receiver() {
    that.vptr_->op_(that.data_, &data_);
    std::swap(that.vptr_, vptr_);
  }

template<class E, class... VN>

requires ReceiveValue<wrapped_t<Wrapped>, VN...>&& ReceiveError< Wrapped, E> folly::pushmi::any_receiver< E, VN >::any_receiver ( Wrapped  obj )

inlineexplicitnoexcept

Definition at line 129 of file receiver.h.

      : any_receiver{std::move(obj), bool_<insitu<Wrapped>()>{}} {
    check<Wrapped>();
  }

template<class E, class... VN>

folly::pushmi::any_receiver< E, VN >::~any_receiver ( )

inline

Definition at line 133 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::operator=().

                  {
    vptr_->op_(data_, nullptr);
  }

Member Function Documentation

template<class E, class... VN>

template<class Wrapped >

static void folly::pushmi::any_receiver< E, VN >::check ( )

inlinestaticprivate

Definition at line 60 of file receiver.h.

                      {
    static_assert(
        ReceiveValue<Wrapped, VN...>,
        "Wrapped receiver must support values of type VN...");
    static_assert(
        ReceiveError<Wrapped, std::exception_ptr>,
        "Wrapped receiver must support std::exception_ptr and be noexcept");
    static_assert(
        NothrowInvocable<decltype(::folly::pushmi::set_error), Wrapped, E>,
        "Wrapped receiver must support E and be noexcept");
  }

template<class E, class... VN>

void folly::pushmi::any_receiver< E, VN >::done ( )

inline

Definition at line 153 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver().

              {
    if (!done_) {
      done_ = true;
      vptr_->done_(data_);
    }
  }

template<class E, class... VN>

void folly::pushmi::any_receiver< E, VN >::error ( E  e )

inlinenoexcept

Definition at line 147 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver().

                           {
    if (!done_) {
      done_ = true;
      vptr_->error_(data_, std::move(e));
    }
  }

template<class E, class... VN>

template<class Wrapped >

static constexpr bool folly::pushmi::any_receiver< E, VN >::insitu ( )

inlinestaticprivatenoexcept

Definition at line 39 of file receiver.h.

                                          {
    return sizeof(Wrapped) <= sizeof(data::buffer_) &&
        std::is_nothrow_move_constructible<Wrapped>::value;
  }

template<class E, class... VN>

any_receiver& folly::pushmi::any_receiver< E, VN >::operator= ( any_receiver< E, VN > &&  that )

inlinenoexcept

Definition at line 136 of file receiver.h.

                                                        {
    this->~any_receiver();
    new ((void*)this) any_receiver(std::move(that));
    return *this;
  }

template<class E, class... VN>

void folly::pushmi::any_receiver< E, VN >::value ( VN &&...  vn )

inline

Definition at line 141 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver().

                         {
    if (!done_) {
      // done_ = true;
      vptr_->value_(data_, (VN &&) vn...);
    }
  }

Member Data Documentation

template<class E, class... VN>

union folly::pushmi::any_receiver::data folly::pushmi::any_receiver< E, VN >::data_

private

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver(), folly::pushmi::receiver< Data, DVF, DEF, DDF >::data(), folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::done(), folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::error(), folly::pushmi::receiver< Data, DVF, DEF, DDF >::receiver(), folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::value(), and folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::~any_receiver().

template<class E, class... VN>

bool folly::pushmi::any_receiver< E, VN >::done_ = false

private

Definition at line 33 of file receiver.h.

Referenced by folly::pushmi::receiver< VF, EF, DF >::receiver(), and folly::pushmi::receiver< Data, DVF, DEF, DDF >::receiver().

template<class E, class... VN>

constexpr any_receiver< E, VN... >::vtable const folly::pushmi::any_receiver< E, VN >::noop_ {}

staticprivate

Definition at line 55 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::done().

template<class E, class... VN>

vtable const* folly::pushmi::any_receiver< E, VN >::vptr_ = &noop_

private

Definition at line 56 of file receiver.h.

Referenced by folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver().

---

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

• proxygen/folly/folly/experimental/pushmi/forwards.h
• proxygen/folly/folly/experimental/pushmi/receiver.h