folly::pushmi::detail::blocking_submit_fn::fn< AN > Struct Template Reference

Public Member Functions
requires Sender< In > &&Invocable< submit_impl< In > &, In &,::folly::pushmi::invoke_result_t< receiver_impl< In >, lock_state *, std::tuple< AN... > && > > &&not AlwaysBlocking< In > In	operator() (In in)

Public Attributes
std::tuple< AN... >	args_

Detailed Description

template<class... AN>
struct folly::pushmi::detail::blocking_submit_fn::fn< AN >

Definition at line 307 of file submit.h.

Member Function Documentation

template<class... AN>

requires Sender<In>&& Invocable< submit_impl<In>&, In&, ::folly::pushmi::invoke_result_t< receiver_impl<In>, lock_state*, std::tuple<AN...>&&> >&& not AlwaysBlocking<In> In folly::pushmi::detail::blocking_submit_fn::fn< AN >::operator() ( In  in )

inline

Definition at line 319 of file submit.h.

References folly::pushmi::detail::blocking_submit_fn::lock_state::done, folly::gen::guard(), folly::pushmi::detail::blocking_submit_fn::lock_state::lock, folly::gen::move, folly::pushmi::detail::blocking_submit_fn::lock_state::nested, folly::pushmi::detail::blocking_submit_fn::lock_state::signaled, and folly::pushmi::submit.

                         {
      lock_state state{};

      auto make = receiver_impl<In>{};
      auto submit = submit_impl<In>{};
      submit(in, make(&state, std::move(args_)));

      std::unique_lock<std::mutex> guard{state.lock};
      state.signaled.wait(
          guard, [&] { return state.done && state.nested.load() == 0; });
      return in;
    }

Member Data Documentation

template<class... AN>

std::tuple<AN...> folly::pushmi::detail::blocking_submit_fn::fn< AN >::args_

Definition at line 308 of file submit.h.

---

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

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