proxygen
|
Public Member Functions | |
std::unique_ptr< folly::IOBuf > | encode (std::string &msg) override |
![]() | |
folly::Future< folly::Unit > | write (Context *ctx, std::stringmsg) override |
![]() | |
~OutboundHandler () override=default | |
virtual folly::Future< folly::Unit > | writeException (Context *ctx, folly::exception_wrapper e) |
virtual folly::Future< folly::Unit > | close (Context *ctx) |
![]() | |
virtual | ~HandlerBase ()=default |
virtual void | attachPipeline (OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > *) |
virtual void | detachPipeline (OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > *) |
OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > * | getContext () |
Additional Inherited Members | |
![]() | |
typedef OutboundHandler< std::string, std::unique_ptr< folly::IOBuf > >::Context | Context |
![]() | |
typedef folly::Unit | rin |
typedef folly::Unit | rout |
typedef std::string | win |
typedef std::unique_ptr< folly::IOBuf > | wout |
typedef OutboundHandlerContext< std::unique_ptr< folly::IOBuf > > | Context |
![]() | |
static const HandlerDir | dir |
A simple encoder that encodes strings of messages to IOBuf. This is used in the ObservingPipeline to encode the messages broadcasted by the upstream to IOBuf so that it can be written to the client socket.
Definition at line 89 of file BroadcastProxy.cpp.
|
inlineoverridevirtual |
Implements wangle::MessageToByteEncoder< std::string >.
Definition at line 91 of file BroadcastProxy.cpp.
References folly::IOBuf::copyBuffer().