Struct TMultiplexedProcessor

pub struct TMultiplexedProcessor { /* private fields */ }

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.

Implementations

impl TMultiplexedProcessor

pub fn new() -> TMultiplexedProcessor

Create a new TMultiplexedProcessor with no registered service-specific processors.

pub fn register<S: Into<String>>( &mut self, service_name: S, processor: Box<dyn TProcessor + Send + Sync>, as_default: bool, ) -> Result<()>

Register a service-specific processor for the service named service_name. This implementation is also backwards-compatible with non-multiplexed clients. Set as_default to true to allow non-namespaced requests to be dispatched to a default processor.

Returns success if a new entry was inserted. Returns an error if:

• A processor exists for service_name
• You attempt to register a processor as default, and an existing default exists

Trait Implementations

impl Debug for TMultiplexedProcessor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TMultiplexedProcessor

fn default() -> TMultiplexedProcessor

Returns the “default value” for a type.

impl TProcessor for TMultiplexedProcessor

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

Process a Thrift service call.