Struct ServerEndpoint

pub struct ServerEndpoint<In: RpcMessage, Out: RpcMessage>(/* private fields */);

A boxed server endpoint

Implementations

impl<In: RpcMessage, Out: RpcMessage> ServerEndpoint<In, Out>

pub fn new(x: impl BoxableServerEndpoint<In, Out>) -> Self

Wrap a boxable server endpoint into a box, transforming all the types to concrete types

Trait Implementations

impl<In: RpcMessage, Out: RpcMessage> Clone for ServerEndpoint<In, Out>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for ServerEndpoint<In, Out>

type RecvStream = RecvStream<In>

Receive side of a bidirectional typed channel

type SendSink = SendSink<Out>

Send side of a bidirectional typed channel

impl<In: RpcMessage, Out: RpcMessage> ConnectionErrors for ServerEndpoint<In, Out>

type OpenError = Error

Error when opening or accepting a channel

type SendError = Error

Error when sending a message via a channel

type RecvError = Error

Error when receiving a message via a channel

impl<In: Debug + RpcMessage, Out: Debug + RpcMessage> Debug for ServerEndpoint<In, Out>

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

Formats the value using the given formatter.

impl<In: RpcMessage, Out: RpcMessage> ServerEndpoint<In, Out> for ServerEndpoint<In, Out>

fn accept( &self, ) -> impl Future<Output = Result<(Self::SendSink, Self::RecvStream), Self::OpenError>> + Send

Accept a new typed bidirectional channel on any of the connections we have currently opened.

fn local_addr(&self) -> &[LocalAddr]

The local addresses this endpoint is bound to.