ImmediateFlowManySender Class Reference

Inheritance diagram for ImmediateFlowManySender:

Protected Member Functions
auto	make_producer ()
template<class F >
auto	make_consumer (F f)
Protected Member Functions inherited from testing::Test
	Test ()
virtual void	SetUp ()
virtual void	TearDown ()
	Test ()
virtual void	SetUp ()
virtual void	TearDown ()
	Test ()
virtual void	SetUp ()
virtual void	TearDown ()

Protected Attributes
int	signals_ {0}

Additional Inherited Members
Public Types inherited from testing::Test
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc
typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc
Public Member Functions inherited from testing::Test
virtual	~Test ()
virtual	~Test ()
virtual	~Test ()
Static Public Member Functions inherited from testing::Test
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)
static void	SetUpTestCase ()
static void	TearDownTestCase ()
static bool	HasFatalFailure ()
static bool	HasNonfatalFailure ()
static bool	HasFailure ()
static void	RecordProperty (const std::string &key, const std::string &value)
static void	RecordProperty (const std::string &key, int value)

Detailed Description

Definition at line 49 of file FlowManyTest.cpp.

Member Function Documentation

template<class F >

auto ImmediateFlowManySender::make_consumer ( F  f )

inlineprotected

Definition at line 90 of file FlowManyTest.cpp.

References f, MAKE, folly::gen::move, folly::pushmi::__adl::noexcept(), folly::pushmi::on_done(), folly::pushmi::on_error(), folly::pushmi::on_starting(), and folly::pushmi::on_value().

                          {
    return mi::MAKE(flow_receiver)(
        mi::on_value([&](int) { signals_ += 100; }),
        mi::on_error([&](auto) noexcept { signals_ += 1000; }),
        mi::on_done([&]() { signals_ += 1; }),
        mi::on_starting([&, f](auto up) {
          signals_ += 10;
          f(std::move(up));
        }));
  }

auto ImmediateFlowManySender::make_producer ( )

inlineprotected

Definition at line 51 of file FlowManyTest.cpp.

References data, MAKE, folly::gen::move, folly::pushmi::__adl::noexcept(), folly::pushmi::set_done, folly::pushmi::set_starting, folly::pushmi::set_value, and stop().

                       {
    return mi::MAKE(flow_many_sender)([&](auto out) {
      using Out = decltype(out);
      struct Data : mi::receiver<> {
        explicit Data(Out out) : out(std::move(out)), stop(false) {}
        Out out;
        bool stop;
      };

      auto up = mi::MAKE(receiver)(
          Data{std::move(out)},
          [&](auto& data, auto requested) {
            signals_ += 1000000;
            if (requested < 1) {
              return;
            }
            // check boolean to select signal
            if (!data.stop) {
              ::mi::set_value(data.out, 42);
            }
            ::mi::set_done(data.out);
          },
          [&](auto& data, auto) noexcept {
            signals_ += 100000;
            data.stop = true;
            ::mi::set_done(data.out);
          },
          [&](auto& data) {
            signals_ += 10000;
            data.stop = true;
            ::mi::set_done(data.out);
          });

      // pass reference for cancellation.
      ::mi::set_starting(up.data().out, std::move(up));
    });
  }

Member Data Documentation

int ImmediateFlowManySender::signals_ {0}

protected

Definition at line 101 of file FlowManyTest.cpp.

---

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

• proxygen/folly/folly/experimental/pushmi/test/FlowManyTest.cpp