Trait 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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<A: Connection<In, Out>, B: Connection<In, Out>, In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for CombinedConnection<A, B, In, Out>

type RecvStream = RecvStream<A, B, In, Out>

type SendSink = SendSink<A, B, In, Out>

impl<A: ServerEndpoint<In, Out>, B: ServerEndpoint<In, Out>, In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for CombinedServerEndpoint<A, B, In, Out>

type RecvStream = RecvStream<A, B, In, Out>

type SendSink = SendSink<A, B, In, Out>

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

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

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 FlumeConnection<In, Out>

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type RecvStream = RecvStream<In>

type SendSink = SendSink<Out>

impl<In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for HyperServerEndpoint<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> + Unpin + Send + Sync>

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

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>

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

type SendSink = SendSink<Out>

type RecvStream = RecvStream<In>