Struct MappedConnector

pub struct MappedConnector<In, Out, C> { /* private fields */ }

A connection that maps input and output types

Implementations

impl<In, Out, C> MappedConnector<In, Out, C>

where C: Connector, In: TryFrom<C::In>, C::Out: From<Out>,

pub fn new(inner: C) -> Self

Create a new mapped connection

Trait Implementations

impl<In, Out, C> BoxableConnector<In, Out> for MappedConnector<In, Out, C>

where In: RpcMessage + TryFrom<C::In>, Out: RpcMessage, C: Connector, C::Out: From<Out>, C::SendError: Into<Error>, C::RecvError: Into<Error>, C::OpenError: Into<Error>,

fn clone_box(&self) -> Box<dyn BoxableConnector<In, Out>>

Clone the connection and box it

fn open_boxed(&self) -> OpenFuture<'_, In, Out>

Open a channel to the remote che

impl<In, Out, C> Clone for MappedConnector<In, Out, C>

where C: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<In, Out, C> ConnectionErrors for MappedConnector<In, Out, C>

where In: RpcMessage, Out: RpcMessage, C: ConnectionErrors,

type RecvError = ErrorOrMapError<<C as ConnectionErrors>::RecvError>

Error when receiving a message via a channel

type SendError = <C as ConnectionErrors>::SendError

Error when sending a message via a channel

type OpenError = <C as ConnectionErrors>::OpenError

Error when opening a channel

type AcceptError = <C as ConnectionErrors>::AcceptError

Error when accepting a channel

impl<In, Out, C> Connector for MappedConnector<In, Out, C>

where C: Connector, In: RpcMessage + TryFrom<C::In>, Out: RpcMessage, C::Out: From<Out>,

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

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<In: Debug, Out: Debug, C: Debug> Debug for MappedConnector<In, Out, C>

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

Formats the value using the given formatter.

impl<In, Out, C> StreamTypes for MappedConnector<In, Out, C>

where C: StreamTypes, In: RpcMessage + TryFrom<C::In>, Out: RpcMessage, C::Out: From<Out>,

type In = In

The type of messages that can be received on the channel

type Out = Out

The type of messages that can be sent on the channel

type RecvStream = MappedRecvStream<<C as StreamTypes>::RecvStream, In>

Receive side of a bidirectional typed channel

type SendSink = MappedSendSink<<C as StreamTypes>::SendSink, Out, <C as StreamTypes>::Out>

Send side of a bidirectional typed channel