Struct QuinnConnection

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

A connection using a quinn connection

Implementations

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

pub fn from_connection(connection: Connection) -> Self

Create a new channel

pub fn new(endpoint: Endpoint, addr: SocketAddr, name: String) -> Self

Create a new channel

Trait Implementations

impl<In: RpcMessage, Out: RpcMessage> BoxableConnection<In, Out> for QuinnConnection<In, Out>

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

Clone the connection and box it

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

Open a channel to the remote che

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

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

Open a channel to the remote che

impl<In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for QuinnConnection<In, Out>

type SendSink = SendSink<Out>

Send side of a bidirectional typed channel

type RecvStream = RecvStream<In>

Receive side of a bidirectional typed channel

impl<In: RpcMessage, Out: RpcMessage> ConnectionErrors for QuinnConnection<In, Out>

type SendError = Error

Error when sending a message via a channel

type RecvError = Error

Error when receiving a message via a channel

type OpenError = ConnectionError

Error when opening or accepting a channel

impl<In: RpcMessage, Out: RpcMessage> Debug for QuinnConnection<In, Out>

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

Formats the value using the given formatter.