Struct quic_rpc::transport::flume::FlumeConnection

pub struct FlumeConnection<S: Service> { /* private fields */ }

A flume based connection to a server endpoint.

Created using connection.

Trait Implementations

impl<S: Service> BoxableConnection<<S as Service>::Res, <S as Service>::Req> for FlumeConnection<S>

fn clone_box(&self) -> Box<dyn BoxableConnection<S::Res, S::Req>>

Clone the connection and box it

fn open_bi_boxed(&self) -> OpenFuture<'_, S::Res, S::Req>

Open a channel to the remote che

impl<S: Service> Clone for FlumeConnection<S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Service> Connection<<S as Service>::Res, <S as Service>::Req> for FlumeConnection<S>

fn open_bi(&self) -> OpenBiFuture<S::Res, S::Req>

Open a channel to the remote che

impl<S: Service> ConnectionCommon<<S as Service>::Res, <S as Service>::Req> for FlumeConnection<S>

type SendSink = SendSink<<S as Service>::Req>

Send side of a bidirectional typed channel

type RecvStream = RecvStream<<S as Service>::Res>

Receive side of a bidirectional typed channel

impl<S: Service> ConnectionErrors for FlumeConnection<S>

type SendError = SendError

Error when sending a message via a channel

type RecvError = RecvError

Error when receiving a message via a channel

type OpenError = OpenBiError

Error when opening or accepting a channel

impl<S: Service> Debug for FlumeConnection<S>

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

Formats the value using the given formatter.