Struct quic_rpc::server::RpcServer

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

A server channel for a specific service.

This is a wrapper around a ServiceEndpoint that serves as the entry point for the server DSL. S is the service type, C is the channel type.

Implementations

impl<S: Service, C: ServiceEndpoint<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 ServiceEndpoint.

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

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

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

Accepts a new channel from a client, and reads the first request.

The return value is a tuple of (request, channel). Here request is the first request which is already read from the stream. The channel is a RpcChannel that has sink and stream fields that can be used to send more requests and/or receive more responses.

Often sink and stream will wrap an an underlying byte stream. In this case you can call into_inner() on them to get it back to perform byte level reads and writes.

pub fn into_inner(self) -> C

Get the underlying service endpoint

Trait Implementations

impl<S: Service, C: ServiceEndpoint<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.