Struct quic_rpc::transport::combined::CombinedConnection

pub struct CombinedConnection<A, B, S> {
    pub a: Option<A>,
    pub b: Option<B>,
    /* private fields */
}

A connection that combines two other connections

Fields

a: Option<A>

First connection

b: Option<B>

Second connection

Implementations

impl<A: Connection<S::Res, S::Req>, B: Connection<S::Res, S::Req>, S: Service> CombinedConnection<A, B, S>

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

Create a combined connection from two other connections

It will always use the first connection that is not None.

Trait Implementations

impl<A: Clone, B: Clone, S: Service> Clone for CombinedConnection<A, B, S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Connection<S::Res, S::Req>, B: Connection<S::Res, S::Req>, S: Service> Connection<<S as Service>::Res, <S as Service>::Req> for CombinedConnection<A, B, S>

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

Open a channel to the remote che

impl<A: Connection<S::Res, S::Req>, B: Connection<S::Res, S::Req>, S: Service> ConnectionCommon<<S as Service>::Res, <S as Service>::Req> for CombinedConnection<A, B, S>

type RecvStream = RecvStream<A, B, <S as Service>::Res, <S as Service>::Req>

Receive side of a bidirectional typed channel

type SendSink = SendSink<A, B, <S as Service>::Res, <S as Service>::Req>

Send side of a bidirectional typed channel

impl<A: ConnectionErrors, B: ConnectionErrors, S: Service> ConnectionErrors for CombinedConnection<A, B, S>

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 = OpenBiError<A, B>

Error when opening or accepting a channel

impl<A: Debug, B: Debug, S: Service> Debug for CombinedConnection<A, B, S>

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

Formats the value using the given formatter.