|
| MockObservingHandler (BroadcastPool< int, std::string > *broadcastPool) |
|
| MOCK_METHOD2 (mockWrite, folly::MoveWrapper< folly::Future< folly::Unit >>(Context *, int)) |
|
| MOCK_METHOD1 (mockClose, folly::MoveWrapper< folly::Future< folly::Unit >>(Context *)) |
|
folly::Future< folly::Unit > | write (Context *ctx, int data) override |
|
folly::Future< folly::Unit > | close (Context *ctx) override |
|
Public Member Functions inherited from wangle::ObservingHandler< int, std::string > |
| ObservingHandler (const std::string &routingData, BroadcastPool< int, std::string, DefaultPipeline > *broadcastPool) |
|
| ObservingHandler (const ObservingHandler &)=delete |
|
| ObservingHandler (ObservingHandler &&)=default |
|
| ~ObservingHandler () override |
|
ObservingHandler & | operator= (const ObservingHandler &)=delete |
|
ObservingHandler & | operator= (ObservingHandler &&)=default |
|
void | transportActive (Context *ctx) override |
|
void | readEOF (Context *ctx) override |
|
void | readException (Context *ctx, folly::exception_wrapper ex) override |
|
void | onNext (const int &buf) override |
|
void | onError (folly::exception_wrapper ex) override |
|
void | onCompleted () override |
|
std::string & | routingData () override |
|
Public Member Functions inherited from wangle::HandlerAdapter< folly::IOBufQueue &, int > |
void | read (Context *ctx, folly::IOBufQueue &msg) override |
|
folly::Future< folly::Unit > | write (Context *ctx, intmsg) override |
|
Public Member Functions inherited from wangle::Handler< folly::IOBufQueue &, folly::IOBufQueue &, int, int > |
| ~Handler () override=default |
|
virtual void | readEOF (Context *ctx) |
|
virtual void | readException (Context *ctx, folly::exception_wrapper e) |
|
virtual void | transportActive (Context *ctx) |
|
virtual void | transportInactive (Context *ctx) |
|
virtual folly::Future< folly::Unit > | writeException (Context *ctx, folly::exception_wrapper e) |
|
virtual folly::Future< folly::Unit > | close (Context *ctx) |
|
Public Member Functions inherited from wangle::HandlerBase< HandlerContext< folly::IOBufQueue &, int > > |
virtual | ~HandlerBase ()=default |
|
virtual void | attachPipeline (HandlerContext< folly::IOBufQueue &, int > *) |
|
virtual void | detachPipeline (HandlerContext< folly::IOBufQueue &, int > *) |
|
HandlerContext< folly::IOBufQueue &, int > * | getContext () |
|
virtual | ~Subscriber () |
|
Definition at line 100 of file Mocks.h.