Trait quic_rpc::ChannelTypes

pub trait ChannelTypes: Debug + Sized + Send + Sync + Unpin + Clone + 'static {
    type SendSink<M: RpcMessage>: Sink<M, Error = Self::SendError> + Send + Unpin + 'static;
    type RecvStream<M: RpcMessage>: Stream<Item = Result<M, Self::RecvError>> + Send + Unpin + 'static;
    type SendError: RpcError;
    type RecvError: RpcError;
    type OpenBiError: RpcError;
    type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage>: Future<Output = Result<(Self::SendSink<Out>, Self::RecvStream<In>), Self::OpenBiError>> + Send + 'a
    where
        Self: 'a;
    type AcceptBiError: RpcError;
    type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage>: Future<Output = Result<(Self::SendSink<Out>, Self::RecvStream<In>), Self::AcceptBiError>> + Send + 'a
    where
        Self: 'a;
    type ClientChannel<In: RpcMessage, Out: RpcMessage>: ClientChannel<In, Out, Self>;
    type ServerChannel<In: RpcMessage, Out: RpcMessage>: ServerChannel<In, Out, Self>;
}

Defines a set of types for a kind of channel

Every distinct kind of channel has its own ChannelType. See e.g. crate::transport::MemChannelTypes.

Required Associated Types

type SendSink<M: RpcMessage>: Sink<M, Error = Self::SendError> + Send + Unpin + 'static

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

type RecvStream<M: RpcMessage>: Stream<Item = Result<M, Self::RecvError>> + Send + Unpin + 'static

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

type SendError: RpcError

Error you might get while sending messages to a sink

type RecvError: RpcError

Error you might get while receiving messages from a stream

type OpenBiError: RpcError

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

type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage>: Future<Output = Result<(Self::SendSink<Out>, Self::RecvStream<In>), Self::OpenBiError>> + Send + 'a
where
    Self: 'a

Future returned by open_bi

type AcceptBiError: RpcError

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

type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage>: Future<Output = Result<(Self::SendSink<Out>, Self::RecvStream<In>), Self::AcceptBiError>> + Send + 'a
where
    Self: 'a

Future returned by accept_bi

type ClientChannel<In: RpcMessage, Out: RpcMessage>: ClientChannel<In, Out, Self>

Channel type

type ServerChannel<In: RpcMessage, Out: RpcMessage>: ServerChannel<In, Out, Self>

Channel type

Implementors

impl ChannelTypes for quic_rpc::transport::http2::ChannelTypes

type SendSink<M: RpcMessage> = SendSink<M>

type RecvStream<M: RpcMessage> = RecvStream<M>

type SendError = SendError

type RecvError = RecvError

type OpenBiError = OpenBiError

type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage> = OpenBiFuture<'a, In, Out>

type AcceptBiError = AcceptBiError

type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage> = AcceptBiFuture<'a, In, Out>

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

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

impl ChannelTypes for quic_rpc::transport::mem::ChannelTypes

type SendSink<M: RpcMessage> = SendSink<M>

type RecvStream<M: RpcMessage> = RecvStream<M>

type SendError = SendError

type RecvError = RecvError

type OpenBiError = OpenBiError

type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage> = OpenBiFuture<'a, In, Out>

type AcceptBiError = AcceptBiError

type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage> = AcceptBiFuture<'a, In, Out>

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

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

impl ChannelTypes for quic_rpc::transport::quinn::ChannelTypes

type SendSink<M: RpcMessage> = SendSink<M>

type RecvStream<M: RpcMessage> = RecvStream<M>

type OpenBiError = ConnectionError

type AcceptBiError = ConnectionError

type SendError = Error

type RecvError = Error

type OpenBiFuture<'a, In: RpcMessage, Out: RpcMessage> = OpenBiFuture<'a, In, Out>

type AcceptBiFuture<'a, In: RpcMessage, Out: RpcMessage> = AcceptBiFuture<'a, In, Out>

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

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

impl<A: CT, B: CT> ChannelTypes for quic_rpc::transport::combined::ChannelTypes<A, B>

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

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

type SendError = SendError<A, B>

type RecvError = RecvError<A, B>

type OpenBiError = OpenBiError<A, B>

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>>

type AcceptBiError = AcceptBiError<A, B>

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>>

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

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