folly::pushmi::operators Namespace Reference

Classes
struct	bulk_fn
struct	defer_fn
struct	flow_from_fn
struct	flow_from_producer
struct	flow_from_up
struct	from_fn
struct	just_fn

Functions
template<class... VN>
auto	empty ()
requires And< SemiMovable< VN >... > &&SemiMovable< E > auto	error (E e)

Variables
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::bulk_fn	bulk
PUSHMI_INLINE_VAR constexpr detail::no_fail_fn	no_fail {}
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::defer_fn	defer
PUSHMI_INLINE_VAR constexpr detail::filter_fn	filter {}
PUSHMI_INLINE_VAR constexpr detail::for_each_fn	for_each {}
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::from_fn	from
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::flow_from_fn	flow_from
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::just_fn	just
PUSHMI_INLINE_VAR constexpr detail::on_fn	on {}
PUSHMI_INLINE_VAR constexpr detail::request_via_fn	request_via {}
template<class... TN>
PUSHMI_INLINE_VAR constexpr detail::share_fn< TN... >	share {}
PUSHMI_INLINE_VAR constexpr detail::submit_fn	submit {}
PUSHMI_INLINE_VAR constexpr detail::submit_at_fn	submit_at {}
PUSHMI_INLINE_VAR constexpr detail::submit_after_fn	submit_after {}
PUSHMI_INLINE_VAR constexpr detail::blocking_submit_fn	blocking_submit {}
template<class T >
PUSHMI_INLINE_VAR constexpr detail::get_fn< T >	get {}
PUSHMI_INLINE_VAR constexpr detail::switch_on_error_fn	switch_on_error {}
PUSHMI_INLINE_VAR constexpr detail::tap_fn	tap {}
PUSHMI_INLINE_VAR constexpr detail::transform_fn	transform {}
PUSHMI_INLINE_VAR constexpr detail::via_fn	via {}

Function Documentation

template<class... VN>

auto folly::pushmi::operators::empty ( )

inline

Definition at line 46 of file empty.h.

References folly::empty(), and folly::pushmi::make_single_sender.

             {
  return make_single_sender(
      detail::single_empty_sender_base{}, detail::single_empty_impl<VN...>{});
}

requires And<SemiMovable<VN>...>&& SemiMovable<E> auto folly::pushmi::operators::error

(

E

e

)

Definition at line 48 of file error.h.

References folly::pushmi::make_single_sender, and folly::gen::move.

Referenced by folly::pushmi::any_flow_receiver< PE, PV, E, VN >::any_flow_receiver(), folly::pushmi::any_receiver< E, folly::pushmi::any_executor_ref< E > >::any_receiver(), folly::expected_detail::ExpectedStorage< Value, Error >::assign(), folly::expected_detail::ExpectedStorage< Value, Error, StorageType::eUnion >::assign(), folly::expected_detail::ExpectedStorage< Value, Error, StorageType::ePODStruct >::assign(), folly::expected_detail::ExpectedStorage< Value, Error, StorageType::eUnion >::assignError(), checkItemParseError(), folly::expected_detail::ExpectedStorage< Value, Error, StorageType::eUnion >::clear(), folly::FormatArg::doSplitKey(), folly::FormatArg::enforce(), folly::Expected< int, E >::error(), fizz::test::ProtocolTest< ClientTypes, Actions >::expectError(), fizz::test::ProtocolTest< ClientTypes, Actions >::expectExceptionType(), HTTPDownstreamTest< SPDY3_1CodecPair >::expectResponses(), proxygen::HTTPDirectResponseHandler::forceConnectionClose(), folly::SocketAddress::getAddrInfo(), proxygen::getErrorString(), proxygen::HTTPTransaction::getMaxDeferredSize(), proxygen::HTTPSession::getSecurityProtocol(), testing::internal::GetTimeInMillis(), http_parser_execute(), folly::FormatArg::initSlow(), folly::AsyncTransport::isPending(), main(), proxygen::HTTP2Codec::maxRecvFrameSize(), fizz::test::MockAsyncFizzBase::MockAsyncFizzBase(), proxygen::HTTPCodec::Callback::onChunkComplete(), proxygen::HTTPTransactionHandler::onChunkComplete(), proxygen::CodecErrorResponseHandler::onError(), proxygen::HTTPDirectResponseHandler::onError(), proxygen::PushHandler::InnerPushHandler::onError(), proxygen::RequestHandlerAdaptor::onError(), proxygen::HTTPMessageFilter::onError(), CurlService::CurlClient::onError(), proxygen::FakeHTTPCodecCallback::onError(), proxygen::HTTPSession::onError(), proxygen::HTTP1xCodec::onHeadersComplete(), proxygen::HTTP1xCodec::onParserError(), ProxyService::ProxyHandler::onServerError(), proxygen::MockHTTPHandler::onTrailers(), ProxyService::ProxyHandler::onUpgrade(), proxygen::PassThroughHTTPCodecFilter::PassThroughHTTPCodecFilter(), folly::Subprocess::prepareChild(), wangle::Acceptor::processEstablishedConnection(), folly::pushmi::__adl::requires(), folly::NestedCommandLineApp::run(), proxygen::HTTPSessionBase::setSessionStats(), testing::internal::ShouldRunTestCase(), proxygen::HTTPSession::shutdownTransport(), folly::FormatArg::splitIntKey(), proxygen::HTTP2Codec::streamError(), fizz::test::AsyncFizzBaseTest::TearDown(), TEST(), folly::TEST(), TEST_F(), fizz::server::test::TEST_F(), fizz::client::test::TEST_F(), TEST_P(), test_scan(), folly::expected_detail::expected_detail_ExpectedHelper::ExpectedHelper::then_(), folly::expected_detail::expected_detail_ExpectedHelper::ExpectedHelper::thenOrThrow_(), folly::pushmi::detail::via_fn_data< Executor, Out >::via_fn_data(), and proxygen::HTTPSessionController::~HTTPSessionController().

                {
  return make_single_sender(
      detail::single_error_sender_base{},
      detail::single_error_impl<E, VN...>{std::move(e)});
}

Variable Documentation

PUSHMI_INLINE_VAR constexpr detail::blocking_submit_fn folly::pushmi::operators::blocking_submit {}

Definition at line 389 of file submit.h.

Referenced by constrained_single_sender_test(), folly::pushmi::for_each_fn::operator()(), TEST_F(), and time_single_sender_test().

PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::bulk_fn folly::pushmi::operators::bulk

Referenced by folly::pushmi::operators::bulk_fn::operator()(), folly::pushmi::reduce_fn::operator()(), and folly::pushmi::for_each_fn::operator()().

PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::defer_fn folly::pushmi::operators::defer

Referenced by defer_construction(), folly::pushmi::operators::defer_fn::operator()(), and folly::SemiFuture< T >::SemiFuture().

PUSHMI_INLINE_VAR constexpr detail::filter_fn folly::pushmi::operators::filter {}

Definition at line 75 of file filter.h.

Referenced by accuracy_test(), testing::InitGoogleTestTest::CheckFlags(), ZlibServerFilterTest::exercise_compression(), testing::Flags::Filter(), testing::internal::UnitTestOptions::FilterMatchesTest(), proxygen::FilterChain< HTTPCodec, HTTPCodec::Callback, PassThroughHTTPCodecFilter,&HTTPCodec::setCallback, true >::foreach(), testing::GetDefaultFilter(), testing::internal::GTestFlagSaver::GTestFlagSaver(), cpp.ast.AstBuilder::handle_continue(), main(), cpp.gmock_class::main(), cpp.ast::main(), testing::internal::UnitTestOptions::MatchesFilter(), folly::Future< folly::folly::Unit >::onError(), proxygen::HTTPServerAcceptor::onNewConnection(), testing::internal::PrettyUnitTestResultPrinter::OnTestIterationStart(), testing::internal::PrettyUnitTestResultPrinter::OnTestProgramEnd(), testing::internal::TestPropertyKeyIs::operator()(), testing::internal::ParseGoogleTestFlag(), testing::PrintFlag(), testing::InitGoogleTestTest::SetUp(), testing::internal::ShouldRunTestCase(), TEST(), wangle::TEST(), TEST_F(), testing::Flags::ThrowOnFailure(), testing::internal::UnitTestRecordPropertyTestHelper::UnitTestRecordProperty(), and testing::internal::GTestFlagSaver::~GTestFlagSaver().

PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::flow_from_fn folly::pushmi::operators::flow_from

Referenced by folly::pushmi::operators::flow_from_fn::operator()(), and TEST().

PUSHMI_INLINE_VAR constexpr detail::for_each_fn folly::pushmi::operators::for_each {}

Definition at line 94 of file for_each.h.

PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::from_fn folly::pushmi::operators::from

Referenced by folly::observer_detail::GraphCycleDetector< NodeId >::addEdge(), testing::internal::ArrayAwareFind(), clause11_21_4_7_2_b(), clause11_21_4_7_2_b1(), clause11_21_4_7_2_b2(), cmake_minimum_required(), testing::internal::CopyArray(), getExceptionStackTraceStack(), testing::internal::WhenDynamicCastToMatcher< To >::MatchAndExplain(), testing::internal::WhenDynamicCastToMatcher< To & >::MatchAndExplain(), folly::pushmi::operators::from_fn::operator()(), testing::internal::DoBothAction< Action1, Action2 >::Impl< F >::Perform(), folly::netops::recvfrom(), folly::observer_detail::GraphCycleDetector< NodeId >::removeEdge(), TEST(), and folly::TEST().

template<class T >

PUSHMI_INLINE_VAR constexpr detail::get_fn<T> folly::pushmi::operators::get {}

Definition at line 391 of file submit.h.

Referenced by folly::MPMCPipeline< Input, Output >::blockingRead(), folly::collect(), folly::collectAllSemiFuture(), folly::detail::extract_default(), folly::ThreadLocalPtr< SubscriberMap >::get(), folly::dynamic::getAddress(), folly::FallbackGetcpu< ThreadId >::getcpu(), folly::fibers::getFiberManager(), folly::RequestContext::getStaticContext(), folly::ThreadLocalPRNG::operator()(), folly::MPMCPipeline< Input, Output >::read(), folly::ThreadLocalPtr< SubscriberMap >::release(), folly::ThreadLocalPtr< SubscriberMap >::reset(), folly::Random::secureRandom(), folly::MPMCPipeline< Input, Output >::sizeGuess(), proxygen::HTTPServer::start(), TEST(), TEST_F(), folly::to(), folly::try_detail::unwrapTryTupleImpl(), and folly::observer::detail::ObserverCreatorContext< Observable, Traits >::updateValue().

PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::just_fn folly::pushmi::operators::just

Referenced by defer_execution(), get_setting(), main(), folly::pushmi::reduce_fn::operator()(), folly::pushmi::for_each_fn::operator()(), folly::pushmi::operators::just_fn::operator()(), and TEST().

PUSHMI_INLINE_VAR constexpr detail::no_fail_fn folly::pushmi::operators::no_fail {}

Definition at line 59 of file no_fail.h.

Referenced by main().

PUSHMI_INLINE_VAR constexpr detail::on_fn folly::pushmi::operators::on {}

Definition at line 100 of file on.h.

Referenced by cmake_minimum_required(), option(), TEST(), and TEST_F().

PUSHMI_INLINE_VAR constexpr detail::request_via_fn folly::pushmi::operators::request_via {}

Definition at line 61 of file request_via.h.

Referenced by io_operation().

template<class... TN>

PUSHMI_INLINE_VAR constexpr detail::share_fn<TN...> folly::pushmi::operators::share {}

Definition at line 53 of file share.h.

Referenced by fizz::sm::getClientHello(), fizz::getExtension(), fizz::server::getHrrGroup(), fizz::sm::negotiateGroup(), fizz::test::TEST_F(), and fizz::sm::validateGroups().

PUSHMI_INLINE_VAR constexpr detail::submit_fn folly::pushmi::operators::submit {}

Definition at line 386 of file submit.h.

Referenced by folly::pushmi::operators::bulk_fn::operator()(), and folly::pushmi::operators::defer_fn::impl< F >::operator()().

PUSHMI_INLINE_VAR constexpr detail::submit_after_fn folly::pushmi::operators::submit_after {}

Definition at line 388 of file submit.h.

Referenced by TEST_F(), and time_single_sender_test().

PUSHMI_INLINE_VAR constexpr detail::submit_at_fn folly::pushmi::operators::submit_at {}

Definition at line 387 of file submit.h.

Referenced by ConcurrentFlowManySender::cancellation_test(), ConcurrentFlowSingleSender::cancellation_test(), TEST_F(), and time_single_sender_test().

PUSHMI_INLINE_VAR constexpr detail::switch_on_error_fn folly::pushmi::operators::switch_on_error {}

Definition at line 78 of file switch_on_error.h.

Referenced by main().

PUSHMI_INLINE_VAR constexpr detail::tap_fn folly::pushmi::operators::tap {}

Definition at line 126 of file tap.h.

Referenced by defer_execution(), io_operation(), main(), and TEST().

PUSHMI_INLINE_VAR constexpr detail::transform_fn folly::pushmi::operators::transform {}

Definition at line 158 of file transform.h.

Referenced by folly::collect(), proxygen::compress::QMINScheme::encode(), extractValues(), proxygen::CodecUtil::hasGzipAndDeflate(), io_operation(), lisp(), main(), pipe(), proxygen::HTTPMessage::setMethod(), proxygen::HPACKHeaderName::storeAddress(), sugar(), TEST(), TEST_F(), p1055::then_execute(), p1055::twoway_execute(), folly::Uri::Uri(), proxygen::URL::URL(), proxygen::Base64::urlDecode(), and proxygen::Base64::urlEncode().

PUSHMI_INLINE_VAR constexpr detail::via_fn folly::pushmi::operators::via {}

Definition at line 166 of file via.h.

Referenced by lisp(), wangle::ExecutorFilter< Bonk, Xtruct >::operator()(), pipe(), sugar(), TEST(), TEST_F(), p1055::then_execute(), and folly::pushmi::send_via< In >::via().