Trait quic_rpc::transport::ConnectionCommon

pub trait ConnectionCommon<In, Out>: ConnectionErrors {
    type RecvStream: Stream<Item = Result<In, Self::RecvError>> + Send + Sync + Unpin + 'static;
    type SendSink: Sink<Out, Error = Self::SendError> + Send + Sync + Unpin + 'static;
}

Types that are common to both Connection and ServerEndpoint.

Having this as a separate trait is useful when writing generic code that works with both.

Required Associated Types

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

Receive side of a bidirectional typed channel

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

Send side of a bidirectional typed channel

Object Safety

This trait is not object safe.

Implementors

impl<A: Connection<S::Res, S::Req>, B: Connection<S::Res, S::Req>, S: Service> ConnectionCommon<<S as Service>::Res, <S as Service>::Req> for CombinedConnection<A, B, S>

type RecvStream = RecvStream<A, B, <S as Service>::Res, <S as Service>::Req>

type SendSink = SendSink<A, B, <S as Service>::Res, <S as Service>::Req>

impl<A: ServerEndpoint<S::Req, S::Res>, B: ServerEndpoint<S::Req, S::Res>, S: Service> ConnectionCommon<<S as Service>::Req, <S as Service>::Res> for CombinedServerEndpoint<A, B, S>

type RecvStream = RecvStream<A, B, <S as Service>::Req, <S as Service>::Res>

type SendSink = SendSink<A, B, <S as Service>::Req, <S as Service>::Res>

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

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

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

type RecvStream = Pending<Result<In, <DummyServerEndpoint as ConnectionErrors>::RecvError>>

type SendSink = Box<dyn Sink<Out, Error = <DummyServerEndpoint as ConnectionErrors>::SendError> + Sync + Send + Unpin>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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