proxygen: folly::pushmi::operators::flow_from_fn::out_impl< I, S, Exec

Public Member Functions
requires ReceiveValue< Out, typename std::iterator_traits< I >::value_type > void	operator() (Out out) const

Public Attributes
I	begin_

S	end_

Exec	exec_

Detailed Description

template<class I, class S, class Exec>
struct folly::pushmi::operators::flow_from_fn::out_impl< I, S, Exec >

Definition at line 140 of file from.h.

Member Function Documentation

template<class I , class S , class Exec >

requires ReceiveValue< Out, typename std::iterator_traits<I>::value_type> void folly::pushmi::operators::flow_from_fn::out_impl< I, S, Exec >::operator() ( Out out ) const

inline

Definition at line 148 of file from.h.

References end_, folly::pushmi::make_receiver, folly::gen::move, folly::pushmi::PUSHMI_TEMPLATE(), folly::pushmi::requires(), folly::pushmi::set_starting, and submit.

                                    {
       using Producer = flow_from_producer<I, S, Out, Exec>;
       auto p = std::make_shared<Producer>(
           begin_, end_, std::move(out), exec_, false);
 
       ::folly::pushmi::submit(
           exec_, make_receiver([p](auto) {
             // pass reference for cancellation.
             set_starting(p->out, make_receiver(flow_from_up<Producer>{p}));
           }));
     }