wangle::BroadcastHandler< T, R > Member List

This is the complete list of members for wangle::BroadcastHandler< T, R >, including all inherited members.

attachPipeline(HandlerContext< T, std::unique_ptr< folly::IOBuf > > *)	wangle::HandlerBase< HandlerContext< T, std::unique_ptr< folly::IOBuf > > >	inlinevirtual
close(Context *ctx)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
closeIfIdle()	wangle::BroadcastHandler< T, R >	virtual
Context typedef	wangle::BroadcastHandler< T, R >
detachPipeline(HandlerContext< T, std::unique_ptr< folly::IOBuf > > *)	wangle::HandlerBase< HandlerContext< T, std::unique_ptr< folly::IOBuf > > >	inlinevirtual
dir	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	static
forEachSubscriber(FUNC f)	wangle::BroadcastHandler< T, R >	inlineprotected
getArbitraryIdentifier()	wangle::BroadcastHandler< T, R >
getContext()	wangle::HandlerBase< HandlerContext< T, std::unique_ptr< folly::IOBuf > > >	inline
identifier_	wangle::BroadcastHandler< T, R >	private
nextSubscriptionId_	wangle::BroadcastHandler< T, R >	private
onData(T &)	wangle::BroadcastHandler< T, R >	inlinevirtual
onSubscribe(Subscriber< T, R > *)	wangle::BroadcastHandler< T, R >	inlinevirtual
onUnsubscribe(Subscriber< T, R > *)	wangle::BroadcastHandler< T, R >	inlinevirtual
read(Context *ctx, T data) override	wangle::BroadcastHandler< T, R >
HandlerAdapter< T, std::unique_ptr< folly::IOBuf > >::read(Context *ctx, Tmsg) override	wangle::HandlerAdapter< T, std::unique_ptr< folly::IOBuf > >	inlinevirtual
readEOF(Context *ctx) override	wangle::BroadcastHandler< T, R >
HandlerAdapter< T, std::unique_ptr< folly::IOBuf > >::readEOF(Context *ctx)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
readException(Context *ctx, folly::exception_wrapper ex) override	wangle::BroadcastHandler< T, R >
HandlerAdapter< T, std::unique_ptr< folly::IOBuf > >::readException(Context *ctx, folly::exception_wrapper e)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
rin typedef	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >
rout typedef	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >
subscribe(Subscriber< T, R > *subscriber)	wangle::BroadcastHandler< T, R >	virtual
subscribers_	wangle::BroadcastHandler< T, R >	private
transportActive(Context *ctx)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
transportInactive(Context *ctx)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
unsubscribe(uint64_t subscriptionId)	wangle::BroadcastHandler< T, R >	virtual
win typedef	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >
wout typedef	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >
write(Context *ctx, std::unique_ptr< folly::IOBuf >msg) override	wangle::HandlerAdapter< T, std::unique_ptr< folly::IOBuf > >	inlinevirtual
writeException(Context *ctx, folly::exception_wrapper e)	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >	inlinevirtual
~BroadcastHandler() override	wangle::BroadcastHandler< T, R >	inline
~Handler() override=default	wangle::Handler< T, T, std::unique_ptr< folly::IOBuf >, std::unique_ptr< folly::IOBuf > >
~HandlerBase()=default	wangle::HandlerBase< HandlerContext< T, std::unique_ptr< folly::IOBuf > > >	virtual