folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out > Struct Template Reference

Public Types
using	properties = properties_t< Out >

Public Member Functions
	nested_receiver_impl (lock_state *state, Out out)
template<class V >
void	value (V &&v)
template<class E >
void	error (E &&e) noexcept
void	done ()

Public Attributes
lock_state *	state_
Out	out_

Detailed Description

template<class Out>
struct folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >

Definition at line 136 of file submit.h.

Member Typedef Documentation

template<class Out >

using folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::properties = properties_t<Out>

Definition at line 196 of file submit.h.

Constructor & Destructor Documentation

template<class Out >

folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::nested_receiver_impl ( lock_state *  state, Out  out  )

inline

Definition at line 191 of file submit.h.

        : state_(state), out_(std::move(out)) {}

Member Function Documentation

template<class Out >

void folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::done ( )

inline

Definition at line 212 of file submit.h.

References folly::pushmi::detail::blocking_submit_fn::lock_state::nested, folly::pushmi::set_done, and folly::pushmi::detail::blocking_submit_fn::lock_state::signaled.

                {
      std::exception_ptr e;
      try {
        set_done(out_);
      } catch (...) {
        e = std::current_exception();
      }
      if (--state_->nested == 0) {
        state_->signaled.notify_all();
      }
      if (e) {
        std::rethrow_exception(e);
      }
    }

template<class Out >

template<class E >

void folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::error ( E &&  e )

inlinenoexcept

Definition at line 206 of file submit.h.

References folly::pushmi::detail::blocking_submit_fn::lock_state::nested, folly::pushmi::set_error, and folly::pushmi::detail::blocking_submit_fn::lock_state::signaled.

                               {
      set_error(out_, (E &&) e);
      if (--state_->nested == 0) {
        state_->signaled.notify_all();
      }
    }

template<class Out >

template<class V >

void folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::value ( V &&  v )

inline

Definition at line 199 of file submit.h.

References folly::pushmi::set_value.

                      {
      std::exception_ptr e;
      using executor_t = remove_cvref_t<V>;
      auto n = nested_executor_impl<executor_t>::make(state_, (V &&) v);
      set_value(out_, any_executor_ref<>{n});
    }

Member Data Documentation

template<class Out >

Out folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::out_

Definition at line 194 of file submit.h.

template<class Out >

lock_state* folly::pushmi::detail::blocking_submit_fn::nested_receiver_impl< Out >::state_

Definition at line 193 of file submit.h.

---

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

• proxygen/folly/folly/experimental/pushmi/o/submit.h