Struct ServiceServer 

pub struct ServiceServer<T> { /* private fields */ }

Monomorphic dispatcher for Service.

Unlike .register(Router) which type-erases each method into an Arc<dyn ErasedHandler> stored in a HashMap, this struct dispatches via a compile-time match on method name: no vtable, no hash lookup.

Example

use connectrpc::ConnectRpcService;

let server = ServiceServer::new(MyImpl);
let service = ConnectRpcService::new(server);
// hand `service` to axum/hyper as a fallback_service

Implementations

impl<T: Service> ServiceServer<T>

pub fn new(service: T) -> Self

Wrap a service implementation in a monomorphic dispatcher.

pub fn from_arc(inner: Arc<T>) -> Self

Wrap an already-Arc’d service implementation.

Trait Implementations

impl<T> Clone for ServiceServer<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Service> Dispatcher for ServiceServer<T>

fn lookup(&self, path: &str) -> Option<MethodDescriptor>

Look up a method by its service_name/method_name path.

fn call_unary( &self, path: &str, ctx: RequestContext, request: Payload, format: CodecFormat, ) -> UnaryResult

Dispatch a unary call.

fn call_server_streaming( &self, path: &str, ctx: RequestContext, request: Bytes, format: CodecFormat, ) -> StreamingResult

Dispatch a server-streaming call.

fn call_client_streaming( &self, path: &str, ctx: RequestContext, requests: RequestStream, format: CodecFormat, ) -> UnaryResult

Dispatch a client-streaming call.

fn call_bidi_streaming( &self, path: &str, ctx: RequestContext, requests: RequestStream, format: CodecFormat, ) -> StreamingResult

Dispatch a bidi-streaming call.