Struct CombinedServerEndpoint

pub struct CombinedServerEndpoint<A, B, In, Out> {
    pub a: Option<A>,
    pub b: Option<B>,
    /* private fields */
}

An endpoint that combines two other endpoints

Fields

a: Option<A>

First endpoint

b: Option<B>

Second endpoint

Implementations

impl<A: ServerEndpoint<In, Out>, B: ServerEndpoint<In, Out>, In: RpcMessage, Out: RpcMessage> CombinedServerEndpoint<A, B, In, Out>

pub fn new(a: Option<A>, b: Option<B>) -> Self

Create a combined server endpoint from two other server endpoints

When listening for incoming connections with crate::ServerEndpoint::accept, all configured channels will be listened on, and the first to receive a connection will be used. If no channels are configured, accept_bi will not throw an error but wait forever.

pub fn into_inner(self) -> (Option<A>, Option<B>)

Get back the inner endpoints

Trait Implementations

impl<A: Clone, B: Clone, In: RpcMessage, Out: RpcMessage> Clone for CombinedServerEndpoint<A, B, 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<A: ServerEndpoint<In, Out>, B: ServerEndpoint<In, Out>, In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for CombinedServerEndpoint<A, B, In, Out>

type RecvStream = RecvStream<A, B, In, Out>

Receive side of a bidirectional typed channel

type SendSink = SendSink<A, B, In, Out>

Send side of a bidirectional typed channel

impl<A: ConnectionErrors, B: ConnectionErrors, In: RpcMessage, Out: RpcMessage> ConnectionErrors for CombinedServerEndpoint<A, B, In, Out>

type SendError = SendError<A, B>

Error when sending a message via a channel

type RecvError = RecvError<A, B>

Error when receiving a message via a channel

type OpenError = AcceptBiError<A, B>

Error when opening or accepting a channel

impl<A: Debug, B: Debug, In: RpcMessage, Out: RpcMessage> Debug for CombinedServerEndpoint<A, B, In, Out>

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

Formats the value using the given formatter.

impl<A: ServerEndpoint<In, Out>, B: ServerEndpoint<In, Out>, In: RpcMessage, Out: RpcMessage> ServerEndpoint<In, Out> for CombinedServerEndpoint<A, B, In, Out>

async fn accept( &self, ) -> Result<(Self::SendSink, Self::RecvStream), Self::OpenError>

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.