SimpleBroadcastPipelineFactory Class Reference

Inheritance diagram for SimpleBroadcastPipelineFactory:

Public Member Functions
DefaultPipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > socket) override
BroadcastHandler< std::string, std::string > *	getBroadcastHandler (DefaultPipeline *pipeline) noexceptoverride
void	setRoutingData (DefaultPipeline *, const std::string &) noexceptoverride
Public Member Functions inherited from wangle::PipelineFactory< DefaultPipeline >
virtual DefaultPipeline::Ptr	newPipeline (std::shared_ptr< folly::AsyncUDPSocket >, const folly::SocketAddress &)
virtual	~PipelineFactory ()=default

Detailed Description

BroadcastPipeline maintains the upstream connection and broadcasts messages sent by the upstream server to all the observers/clients.

Definition at line 151 of file BroadcastProxy.cpp.

Member Function Documentation

BroadcastHandler<std::string, std::string>* SimpleBroadcastPipelineFactory::getBroadcastHandler ( DefaultPipeline *  pipeline )

inlineoverridevirtualnoexcept

Implements wangle::BroadcastPipelineFactory< std::string, std::string >.

Definition at line 166 of file BroadcastProxy.cpp.

                                                   {
    return pipeline->getHandler<BroadcastHandler<std::string, std::string>>();
  }

DefaultPipeline::Ptr SimpleBroadcastPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  socket )

inlineoverridevirtual

Implements wangle::BroadcastPipelineFactory< std::string, std::string >.

Definition at line 154 of file BroadcastProxy.cpp.

References folly::INFO.

                                                            {
    LOG(INFO) << "Creating a new BroadcastPipeline for upstream server";

    auto pipeline = DefaultPipeline::create();
    pipeline->addBack(AsyncSocketHandler(socket));
    pipeline->addBack(ByteToStringDecoder());
    pipeline->addBack(BroadcastHandler<std::string, std::string>());
    pipeline->finalize();
    return pipeline;
  }

void SimpleBroadcastPipelineFactory::setRoutingData ( DefaultPipeline *  , const std::string &    )

inlineoverridevirtualnoexcept

Implements wangle::BroadcastPipelineFactory< std::string, std::string >.

Definition at line 171 of file BroadcastProxy.cpp.

                                            {}

---

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

• proxygen/wangle/wangle/example/broadcast/BroadcastProxy.cpp