Struct quic_rpc::transport::combined::ChannelTypes

pub struct ChannelTypes<A: CT, B: CT>(_);

Channel types for combined channels

A and B are the channel types for the two channels. In and Out are the message types for the two channels.

Trait Implementations

impl<A: CT, B: CT> ChannelTypes for ChannelTypes<A, B>

type SendSink<M: RpcMessage> = SendSink<A, B, M>

The sink used for sending either requests or responses on this channel

type RecvStream<M: RpcMessage> = RecvStream<A, B, M>

The stream used for receiving either requests or responses on this channel

type SendError = SendError<A, B>

Error you might get while sending messages to a sink

type RecvError = RecvError<A, B>

Error you might get while receiving messages from a stream

type OpenBiError = OpenBiError<A, B>

Error you might get when opening a new connection to the server

type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage> = Pin<Box<dyn Future<Output = Result<(SendSink<A, B, Out>, RecvStream<A, B, In>), OpenBiError<A, B>>> + Send + 'a, Global>>

Future returned by open_bi

type AcceptBiError = AcceptBiError<A, B>

Error you might get when waiting for new streams on the server side

type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage> = Pin<Box<dyn Future<Output = Result<(SendSink<A, B, Out>, RecvStream<A, B, In>), AcceptBiError<A, B>>> + Send + 'a, Global>>

Future returned by accept_bi

type ClientChannel<In: RpcMessage, Out: RpcMessage> = ClientChannel<A, B, In, Out>

Channel type

type ServerChannel<In: RpcMessage, Out: RpcMessage> = ServerChannel<A, B, In, Out>

Channel type

impl<A: CT, B: CT, In: RpcMessage, Out: RpcMessage> ClientChannel<In, Out, ChannelTypes<A, B>> for ClientChannel<A, B, In, Out>

fn open_bi(&self) -> OpenBiFuture<'_, A, B, In, Out>

Open a bidirectional stream

impl<A: Clone + CT, B: Clone + CT> Clone for ChannelTypes<A, B>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Debug + CT, B: Debug + CT> Debug for ChannelTypes<A, B>

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

Formats the value using the given formatter.

impl<A: CT, B: CT, In: RpcMessage, Out: RpcMessage> ServerChannel<In, Out, ChannelTypes<A, B>> for ServerChannel<A, B, In, Out>

fn local_addr(&self) -> &[LocalAddr]

The local addresses this server is bound to.

fn accept_bi(&self) -> AcceptBiFuture<'_, A, B, In, Out>

Accept a bidirectional stream

impl<A: Copy + CT, B: Copy + CT> Copy for ChannelTypes<A, B>