Struct TracingConfigServer 

pub struct TracingConfigServer<S> { /* private fields */ }

Server dispatcher for the #trait_name service.

Integrate this with an RpcSession by calling RpcSession::set_dispatcher and forwarding method_id/payload into [dispatch] or [dispatch_streaming].

Implementations

impl<S: TracingConfig + Send + Sync + 'static> TracingConfigServer<S>

pub fn new(service: S) -> Self

Create a new server with the given service implementation.

pub async fn serve<T: Transport + 'static>( self, transport: Arc<T>, ) -> Result<(), RpcError>

Serve requests from the transport until the connection closes.

This is the main server loop. It reads frames from the transport, dispatches them to the appropriate method, and sends responses.

Example

let server = CalculatorServer::new(CalculatorImpl);
server.serve(transport).await?;

pub async fn serve_one<T: Transport + 'static>( &self, transport: &T, ) -> Result<(), RpcError>

Serve a single request from the transport.

This is useful for testing or when you want to handle each request individually.

pub async fn dispatch( &self, method_id: u32, request_payload: &[u8], ) -> Result<Frame, RpcError>

Dispatch a request frame to the appropriate method.

Returns a response frame on success for unary methods. For streaming methods, use dispatch_streaming instead.

pub async fn dispatch_streaming<T: Transport + 'static>( &self, method_id: u32, channel_id: u32, request_payload: &[u8], transport: &T, ) -> Result<(), RpcError>

Dispatch a streaming request to the appropriate method.

The method sends frames via the provided transport.