Struct CombinedConnector

pub struct CombinedConnector<A, B> {
    pub a: Option<A>,
    pub b: Option<B>,
}

A connection that combines two other connections

Fields

a: Option<A>

First connection

b: Option<B>

Second connection

Implementations

impl<A: Connector, B: Connector<In = A::In, Out = A::Out>> CombinedConnector<A, B>

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> Clone for CombinedConnector<A, B>

fn clone(&self) -> CombinedConnector<A, B>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: ConnectionErrors, B: ConnectionErrors> ConnectionErrors for CombinedConnector<A, B>

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

Error when opening a channel

type AcceptError = AcceptError<A, B>

Error when accepting a channel

impl<A: Connector, B: Connector<In = A::In, Out = A::Out>> Connector for CombinedConnector<A, B>

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

Open a channel to the remote che

fn map<In1, Out1>(self) -> MappedConnector<In1, Out1, Self>

where In1: TryFrom<Self::In>, Self::Out: From<Out1>,

Map the input and output types of this connection

fn boxed(self) -> BoxedConnector<Self::In, Self::Out>

where Self: BoxableConnector<Self::In, Self::Out> + Sized + 'static,

Box the connection

impl<A: Debug, B: Debug> Debug for CombinedConnector<A, B>

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

Formats the value using the given formatter.

impl<A: Connector, B: Connector<In = A::In, Out = A::Out>> StreamTypes for CombinedConnector<A, B>

type In = <A as StreamTypes>::In

The type of messages that can be received on the channel

type Out = <A as StreamTypes>::Out

The type of messages that can be sent on the channel

type RecvStream = RecvStream<A, B>

Receive side of a bidirectional typed channel

type SendSink = SendSink<A, B>

Send side of a bidirectional typed channel