Struct thrift::server::TMultiplexedProcessor

pub struct TMultiplexedProcessor { /* fields omitted */ }

A TProcessor that can demux service calls to multiple underlying Thrift services.

Users register service-specific TProcessor instances with a TMultiplexedProcessor, and then register that processor with a server implementation. Following that, all incoming service calls are automatically routed to the service-specific TProcessor.

A TMultiplexedProcessor can only handle messages sent by a TMultiplexedOutputProtocol.

Methods

impl TMultiplexedProcessor

fn register_processor<S: Into<String>>(&mut self,
                                       service_name: S,
                                       processor: Box<TProcessor>)
                                       -> bool

Register a service-specific processor for the service named service_name.

Return true if this is the first registration for service_name.

Return false if a mapping previously existed (the previous mapping is not overwritten).

Trait Implementations

impl TProcessor for TMultiplexedProcessor

fn process(&mut self,
           i_prot: &mut TInputProtocol,
           o_prot: &mut TOutputProtocol)
           -> Result<()>

Process a Thrift service call.