|
using | Ptr = std::shared_ptr< Pipeline > |
|
| ~Pipeline () override |
|
template<class T = R> |
std::enable_if<!std::is_same< T, folly::Unit >::value >::type | read (R msg) |
|
template<class T = R> |
std::enable_if<!std::is_same< T, folly::Unit >::value >::type | readEOF () |
|
template<class T = R> |
std::enable_if<!std::is_same< T, folly::Unit >::value >::type | readException (folly::exception_wrapper e) |
|
template<class T = R> |
std::enable_if<!std::is_same< T, folly::Unit >::value >::type | transportActive () |
|
template<class T = R> |
std::enable_if<!std::is_same< T, folly::Unit >::value >::type | transportInactive () |
|
template<class T = W> |
std::enable_if<!std::is_same< T, folly::Unit >::value, folly::Future< folly::Unit > >::type | write (W msg) |
|
template<class T = W> |
std::enable_if<!std::is_same< T, folly::Unit >::value, folly::Future< folly::Unit > >::type | writeException (folly::exception_wrapper e) |
|
template<class T = W> |
std::enable_if<!std::is_same< T, folly::Unit >::value, folly::Future< folly::Unit > >::type | close () |
|
void | finalize () override |
|
virtual | ~PipelineBase ()=default |
|
void | setPipelineManager (PipelineManager *manager) |
|
PipelineManager * | getPipelineManager () |
|
void | deletePipeline () |
|
void | setTransport (std::shared_ptr< folly::AsyncTransport > transport) |
|
std::shared_ptr< folly::AsyncTransport > | getTransport () |
|
void | setWriteFlags (folly::WriteFlags flags) |
|
folly::WriteFlags | getWriteFlags () |
|
void | setReadBufferSettings (uint64_t minAvailable, uint64_t allocationSize) |
|
std::pair< uint64_t, uint64_t > | getReadBufferSettings () |
|
void | setTransportInfo (std::shared_ptr< TransportInfo > tInfo) |
|
std::shared_ptr< TransportInfo > | getTransportInfo () |
|
template<class H > |
PipelineBase & | addBack (std::shared_ptr< H > handler) |
|
template<class H > |
PipelineBase & | addBack (H &&handler) |
|
template<class H > |
PipelineBase & | addBack (H *handler) |
|
template<class H > |
PipelineBase & | addFront (std::shared_ptr< H > handler) |
|
template<class H > |
PipelineBase & | addFront (H &&handler) |
|
template<class H > |
PipelineBase & | addFront (H *handler) |
|
template<class H > |
PipelineBase & | remove (H *handler) |
|
template<class H > |
PipelineBase & | remove () |
|
PipelineBase & | removeFront () |
|
PipelineBase & | removeBack () |
|
template<class H > |
H * | getHandler (int i) |
|
template<class H > |
H * | getHandler () |
|
template<class H > |
ContextType< H >::type * | getContext (int i) |
|
template<class H > |
ContextType< H >::type * | getContext () |
|
template<class H > |
bool | setOwner (H *handler) |
|
size_t | numHandlers () const |
|
static Ptr | create () |
|
std::vector< std::shared_ptr< PipelineContext > > | ctxs_ |
|
std::vector< PipelineContext * > | inCtxs_ |
|
std::vector< PipelineContext * > | outCtxs_ |
|
template<class R, class W>
class wangle::StaticPipeline< R, W >
Definition at line 50 of file StaticPipeline.h.