EchoPipelineFactory Class Reference

Inheritance diagram for EchoPipelineFactory:

Public Member Functions
EchoPipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > sock) override
EchoPipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > sock) override
Public Member Functions inherited from wangle::PipelineFactory< EchoPipeline >
virtual EchoPipeline::Ptr	newPipeline (std::shared_ptr< folly::AsyncUDPSocket >, const folly::SocketAddress &)
virtual	~PipelineFactory ()=default

Detailed Description

Definition at line 53 of file EchoClient.cpp.

Member Function Documentation

EchoPipeline::Ptr EchoPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  sock )

inlineoverridevirtual

Implements wangle::PipelineFactory< EchoPipeline >.

Definition at line 45 of file EchoServer.cpp.

References wangle::Pipeline< R, W >::create().

                                                          {
    auto pipeline = EchoPipeline::create();
    pipeline->addBack(AsyncSocketHandler(sock));
    pipeline->addBack(LineBasedFrameDecoder(8192));
    pipeline->addBack(StringCodec());
    pipeline->addBack(EchoHandler());
    pipeline->finalize();
    return pipeline;
  }

EchoPipeline::Ptr EchoPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  sock )

inlineoverridevirtual

Implements wangle::PipelineFactory< EchoPipeline >.

Definition at line 55 of file EchoClient.cpp.

References wangle::Pipeline< R, W >::create().

                                                          {
    auto pipeline = EchoPipeline::create();
    pipeline->addBack(AsyncSocketHandler(sock));
    pipeline->addBack(
        EventBaseHandler()); // ensure we can write from any thread
    pipeline->addBack(LineBasedFrameDecoder(8192, false));
    pipeline->addBack(StringCodec());
    pipeline->addBack(EchoHandler());
    pipeline->finalize();
    return pipeline;
  }

---

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

• proxygen/wangle/wangle/example/echo/EchoClient.cpp
• proxygen/wangle/wangle/example/echo/EchoServer.cpp