Struct RpcServer

pub struct RpcServer<S, C = BoxedListener<S>> { /* private fields */ }

A server for a specific service.

This is a wrapper around a Listener that serves as the entry point for the server DSL.

Type parameters:

S is the service type. C is the channel type.

Implementations

impl<S: Service, C: Listener<S>> RpcServer<S, C>

pub fn new(source: C) -> Self

Create a new rpc server for a specific service for a Service given a compatible Listener.

This is where a generic typed endpoint is converted into a server for a specific service.

pub fn boxed(self) -> RpcServer<S, BoxedListener<S>>

where C: BoxableListener<S::Req, S::Res>,

Box the transport for the service.

The boxed transport is the default for the C type parameter, so by boxing we can avoid having to specify the type parameter.

impl<S: Service, C: Listener<S>> RpcServer<S, C>

pub async fn accept(&self) -> Result<Accepting<S, C>, RpcServerError<C>>

Accepts a new channel from a client. The result is an Accepting object that can be used to read the first request.

pub fn into_inner(self) -> C

Get the underlying service endpoint

pub async fn accept_loop<Fun, Fut, E>(self, handler: Fun)

where S: Service, C: Listener<S>, Fun: Fn(S::Req, RpcChannel<S, C>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), E>> + Send + 'static, E: Into<Error> + 'static,

Run an accept loop for this server.

Each request will be handled in a separate task.

It is the caller’s responsibility to poll the returned future to drive the server.

pub fn spawn_accept_loop<Fun, Fut, E>( self, handler: Fun, ) -> AbortOnDropHandle<()>

where S: Service, C: Listener<S>, Fun: Fn(S::Req, RpcChannel<S, C>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), E>> + Send + 'static, E: Into<Error> + 'static,

Spawn an accept loop and return a handle to the task.

Trait Implementations

impl<S: Service, C: Listener<S>> AsRef<C> for RpcServer<S, C>

fn as_ref(&self) -> &C

Converts this type into a shared reference of the (usually inferred) input type.

impl<S, C: Clone> Clone for RpcServer<S, C>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug, C: Debug> Debug for RpcServer<S, C>

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

Formats the value using the given formatter.