attachPipeline(HandlerContext< folly::IOBufQueue &, int > *) | wangle::HandlerBase< HandlerContext< folly::IOBufQueue &, int > > | inlinevirtual |
close(Context *ctx) override | wangle::MockObservingHandler | inline |
ObservingHandler< int, std::string >::close(Context *ctx) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
Context typedef | wangle::ObservingHandler< int, std::string > | |
detachPipeline(HandlerContext< folly::IOBufQueue &, int > *) | wangle::HandlerBase< HandlerContext< folly::IOBufQueue &, int > > | inlinevirtual |
dir | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | static |
getContext() | wangle::HandlerBase< HandlerContext< folly::IOBufQueue &, int > > | inline |
MOCK_METHOD1(mockClose, folly::MoveWrapper< folly::Future< folly::Unit >>(Context *)) | wangle::MockObservingHandler | |
MOCK_METHOD2(mockWrite, folly::MoveWrapper< folly::Future< folly::Unit >>(Context *, int)) | wangle::MockObservingHandler | |
MockObservingHandler(BroadcastPool< int, std::string > *broadcastPool) | wangle::MockObservingHandler | inlineexplicit |
ObservingHandler(const std::string &routingData, BroadcastPool< int, std::string, DefaultPipeline > *broadcastPool) | wangle::ObservingHandler< int, std::string > | |
ObservingHandler(const ObservingHandler &)=delete | wangle::ObservingHandler< int, std::string > | |
ObservingHandler(ObservingHandler &&)=default | wangle::ObservingHandler< int, std::string > | |
onCompleted() override | wangle::ObservingHandler< int, std::string > | virtual |
onError(folly::exception_wrapper ex) override | wangle::ObservingHandler< int, std::string > | virtual |
onNext(const int &buf) override | wangle::ObservingHandler< int, std::string > | virtual |
operator=(const ObservingHandler &)=delete | wangle::ObservingHandler< int, std::string > | |
operator=(ObservingHandler &&)=default | wangle::ObservingHandler< int, std::string > | |
read(Context *ctx, folly::IOBufQueue &msg) override | wangle::HandlerAdapter< folly::IOBufQueue &, int > | inlinevirtual |
readEOF(Context *ctx) override | wangle::ObservingHandler< int, std::string > | |
HandlerAdapter< folly::IOBufQueue &, int >::readEOF(Context *ctx) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
readException(Context *ctx, folly::exception_wrapper ex) override | wangle::ObservingHandler< int, std::string > | |
HandlerAdapter< folly::IOBufQueue &, int >::readException(Context *ctx, folly::exception_wrapper e) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
rin typedef | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | |
rout typedef | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | |
routingData() override | wangle::ObservingHandler< int, std::string > | virtual |
transportActive(Context *ctx) override | wangle::ObservingHandler< int, std::string > | |
HandlerAdapter< folly::IOBufQueue &, int >::transportActive(Context *ctx) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
transportInactive(Context *ctx) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
win typedef | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | |
wout typedef | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | |
write(Context *ctx, int data) override | wangle::MockObservingHandler | inline |
ObservingHandler< int, std::string >::write(Context *ctx, intmsg) override | wangle::HandlerAdapter< folly::IOBufQueue &, int > | inlinevirtual |
writeException(Context *ctx, folly::exception_wrapper e) | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | inlinevirtual |
~Handler() override=default | wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > | |
~HandlerBase()=default | wangle::HandlerBase< HandlerContext< folly::IOBufQueue &, int > > | virtual |
~ObservingHandler() override | wangle::ObservingHandler< int, std::string > | |
~Subscriber() | wangle::Subscriber< int, std::string > | inlinevirtual |