folly::pushmi::operators::flow_from_up< Producer > Struct Template Reference

#include <from.h>

Public Types
using	properties = properties_t< receiver<>>

Public Member Functions
	flow_from_up (std::shared_ptr< Producer > p)
void	value (std::ptrdiff_t requested)
template<class E >
void	error (E) noexcept
void	done ()

Public Attributes
std::shared_ptr< Producer >	p

Detailed Description

template<class Producer>
struct folly::pushmi::operators::flow_from_up< Producer >

Definition at line 94 of file from.h.

Member Typedef Documentation

template<class Producer >

using folly::pushmi::operators::flow_from_up< Producer >::properties = properties_t<receiver<>>

Definition at line 95 of file from.h.

Constructor & Destructor Documentation

template<class Producer >

folly::pushmi::operators::flow_from_up< Producer >::flow_from_up ( std::shared_ptr< Producer >  p )

inlineexplicit

Definition at line 97 of file from.h.

: p(std::move(p)) {}

Member Function Documentation

template<class Producer >

void folly::pushmi::operators::flow_from_up< Producer >::done ( )

inline

Definition at line 130 of file from.h.

References folly::pushmi::make_receiver, folly::pushmi::set_done, and submit.

              {
    p->stop.store(true);
    ::folly::pushmi::submit(
        p->exec, make_receiver([p = p](auto) { set_done(p->out); }));
  }

template<class Producer >

template<class E >

void folly::pushmi::operators::flow_from_up< Producer >::error ( E  )

inlinenoexcept

Definition at line 124 of file from.h.

References folly::pushmi::make_receiver, folly::pushmi::set_done, and submit.

                         {
    p->stop.store(true);
    ::folly::pushmi::submit(
        p->exec, make_receiver([p = p](auto) { set_done(p->out); }));
  }

template<class Producer >

void folly::pushmi::operators::flow_from_up< Producer >::value ( std::ptrdiff_t  requested )

inline

Definition at line 100 of file from.h.

References if(), folly::pushmi::make_receiver, and submit.

                                     {
    if (requested < 1) {
      return;
    }
    // submit work to exec
    ::folly::pushmi::submit(
        p->exec, make_receiver([p = p, requested](auto) {
          auto remaining = requested;
          // this loop is structured to work when there is
          // re-entrancy out.value in the loop may call up.value.
          // to handle this the state of p->c must be captured and
          // the remaining and p->c must be changed before
          // out.value is called.
          while (remaining-- > 0 && !p->stop && p->c != p->end) {
            auto i = (p->c)++;
            set_value(p->out, ::folly::pushmi::detail::as_const(*i));
          }
          if (p->c == p->end) {
            set_done(p->out);
          }
        }));
  }

Member Data Documentation

template<class Producer >

std::shared_ptr<Producer> folly::pushmi::operators::flow_from_up< Producer >::p

Definition at line 98 of file from.h.

---

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

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