Struct HyperConnector

pub struct HyperConnector<In: RpcMessage, Out: RpcMessage> { /* private fields */ }

Hyper based connection to a server

Implementations

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

pub fn new(uri: Uri) -> Self

create a client given an uri and the default configuration

pub fn with_config(uri: Uri, config: ChannelConfig) -> Self

create a client given an uri and a custom configuration

pub fn with_connector<C: Connect + Clone + Send + Sync + 'static>( connector: C, uri: Uri, config: Arc<ChannelConfig>, ) -> Self

create a client given an uri and a custom configuration

Trait Implementations

impl<In: RpcMessage, Out: RpcMessage> Clone for HyperConnector<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> ConnectionErrors for HyperConnector<In, Out>

type SendError = SendError

Error when sending a message via a channel

type RecvError = RecvError

Error when receiving a message via a channel

type OpenError = OpenError

Error when opening a channel

type AcceptError = AcceptError

Error when accepting a channel

impl<In: RpcMessage, Out: RpcMessage> Connector for HyperConnector<In, Out>

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<In: RpcMessage, Out: RpcMessage> Debug for HyperConnector<In, Out>

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

Formats the value using the given formatter.

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for HyperConnector<In, 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 = RecvStream<In>

Receive side of a bidirectional typed channel

type SendSink = SendSink<Out>

Send side of a bidirectional typed channel